feat: provide TableDefinition functions for Iceberg tables (deephaven…

…#5891) Fixes deephaven#5868 --------- Co-authored-by: Larry Booker <[email protected]>
devinrsmith · Aug 6, 2024 · 9156dd8 · 9156dd8
1 parent 58ce658
commit 9156dd8
Show file tree

Hide file tree

Showing 3 changed files with 593 additions and 185 deletions.
diff --git a/engine/table/src/main/java/io/deephaven/engine/util/TableTools.java b/engine/table/src/main/java/io/deephaven/engine/util/TableTools.java
@@ -15,6 +15,7 @@
 import io.deephaven.engine.table.*;
 import io.deephaven.engine.table.impl.InMemoryTable;
 import io.deephaven.engine.table.impl.perf.QueryPerformanceRecorder;
+import io.deephaven.engine.table.impl.sources.NullValueColumnSource;
 import io.deephaven.internal.log.LoggerFactory;
 import io.deephaven.time.DateTimeUtils;
 import io.deephaven.engine.table.impl.QueryTable;
@@ -731,7 +732,7 @@ public static Table newTable(long size, Map<String, ColumnSource<?>> columns) {
     public static Table newTable(TableDefinition definition) {
         Map<String, ColumnSource<?>> columns = new LinkedHashMap<>();
         for (ColumnDefinition<?> columnDefinition : definition.getColumns()) {
-            columns.put(columnDefinition.getName(), ArrayBackedColumnSource.getMemoryColumnSource(0,
+            columns.put(columnDefinition.getName(), NullValueColumnSource.getInstance(
                     columnDefinition.getDataType(), columnDefinition.getComponentType()));
         }
         return new QueryTable(definition, RowSetFactory.empty().toTracking(), columns) {