|
13 | 13 | from deephaven.column import byte_col, char_col, short_col, bool_col, int_col, long_col, float_col, double_col, \
|
14 | 14 | string_col, datetime_col, pyobj_col, jobj_col
|
15 | 15 | from deephaven.constants import NULL_DOUBLE, NULL_FLOAT, NULL_LONG, NULL_INT, NULL_SHORT, NULL_BYTE
|
16 |
| -from deephaven.table_factory import DynamicTableWriter, ring_table |
| 16 | +from deephaven.table_factory import DynamicTableWriter, InputTable, ring_table |
17 | 17 | from tests.testbase import BaseTestCase
|
18 | 18 | from deephaven.table import Table
|
19 | 19 | from deephaven.stream import blink_to_append_only, stream_to_append_only
|
20 | 20 |
|
21 | 21 | JArrayList = jpy.get_type("java.util.ArrayList")
|
22 | 22 | _JBlinkTableTools = jpy.get_type("io.deephaven.engine.table.impl.BlinkTableTools")
|
23 | 23 | _JDateTimeUtils = jpy.get_type("io.deephaven.time.DateTimeUtils")
|
| 24 | +_JTable = jpy.get_type("io.deephaven.engine.table.Table") |
24 | 25 |
|
25 | 26 |
|
26 | 27 | @dataclass
|
@@ -372,6 +373,11 @@ def test_input_table(self):
|
372 | 373 | keyed_input_table.delete(t.select(["String", "Double"]))
|
373 | 374 | self.assertEqual(keyed_input_table.size, 0)
|
374 | 375 |
|
| 376 | + with self.subTest("custom input table creation"): |
| 377 | + place_holder_input_table = empty_table(1).update_view(["Key=`A`", "Value=10"]).with_attributes({_JTable.INPUT_TABLE_ATTRIBUTE: "Placeholder IT"}).j_table |
| 378 | + # Confirming no error. |
| 379 | + InputTable(place_holder_input_table) |
| 380 | + |
375 | 381 | def test_ring_table(self):
|
376 | 382 | cols = [
|
377 | 383 | bool_col(name="Boolean", data=[True, False]),
|
|
0 commit comments