Add support for converting stream tables to append from python. (#1090)

* Add support for converting stream tables to append from python. * Followup to review comments. * Followup to review commetns, for realz this time.
deephaven · Aug 19, 2021 · 152b2b8 · 152b2b8
1 parent 41cd9a3
commit 152b2b8
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/Generators/src/main/java/io/deephaven/pythonPreambles/KafkaToolsPreamble.txt b/Generators/src/main/java/io/deephaven/pythonPreambles/KafkaToolsPreamble.txt
@@ -239,9 +239,12 @@ def simple(column_name:str, data_type_str:str = 'string'):
     return _java_type_.simpleSpec(column_name, data_type)
 
 
+@_passThrough
+def streamTableToAppendTable(t):
+    return _stream_table_tools_.streamToAppendOnlyTable(t)
+
 # Define all of our functionality, if currently possible
 try:
     _defineSymbols()
 except Exception as e:
     pass
-
diff --git a/Integrations/python/deephaven/KafkaTools/__init__.py b/Integrations/python/deephaven/KafkaTools/__init__.py
@@ -241,12 +241,15 @@ def simple(column_name:str, data_type_str:str = 'string'):
     return _java_type_.simpleSpec(column_name, data_type)
 
 
+@_passThrough
+def streamTableToAppendTable(t):
+    return _stream_table_tools_.streamToAppendOnlyTable(t)
+
 # Define all of our functionality, if currently possible
 try:
     _defineSymbols()
 except Exception as e:
     pass
-
 @_passThrough
 def avroSchemaToColumnDefinitions(*args):
     """