diff --git a/extensions/barrage/src/main/java/io/deephaven/extensions/barrage/util/BarrageUtil.java b/extensions/barrage/src/main/java/io/deephaven/extensions/barrage/util/BarrageUtil.java index 3b4a1c11423..b246c4fa6b4 100755 --- a/extensions/barrage/src/main/java/io/deephaven/extensions/barrage/util/BarrageUtil.java +++ b/extensions/barrage/src/main/java/io/deephaven/extensions/barrage/util/BarrageUtil.java @@ -423,6 +423,10 @@ private static void setConversionFactor(final ConvertedArrowSchema result, final result.conversionFactors[i] = factor; } + public static TableDefinition convertTableDefinition(final ExportedTableCreationResponse response) { + return convertArrowSchema(SchemaHelper.flatbufSchema(response)).tableDef; + } + public static ConvertedArrowSchema convertArrowSchema(final ExportedTableCreationResponse response) { return convertArrowSchema(SchemaHelper.flatbufSchema(response)); } diff --git a/java-client/barrage/src/main/java/io/deephaven/client/impl/BarrageSnapshot.java b/java-client/barrage/src/main/java/io/deephaven/client/impl/BarrageSnapshot.java index ab1f1759c26..9003f7517e0 100644 --- a/java-client/barrage/src/main/java/io/deephaven/client/impl/BarrageSnapshot.java +++ b/java-client/barrage/src/main/java/io/deephaven/client/impl/BarrageSnapshot.java @@ -56,11 +56,6 @@ BarrageSnapshot snapshot(TableSpec tableSpec, BarrageSnapshotOptions options) BarrageSnapshot snapshot(TableHandle tableHandle, BarrageSnapshotOptions options); } - /** - * @return the {@link TableDefinition} of the subscribed table - */ - TableDefinition getTableDefinition(); - /** * Request a full snapshot of the data and populate a {@link Table} with the data that is received. The returned * future will block until all rows for the snapshot table are available. diff --git a/java-client/barrage/src/main/java/io/deephaven/client/impl/BarrageSnapshotImpl.java b/java-client/barrage/src/main/java/io/deephaven/client/impl/BarrageSnapshotImpl.java index d2f06c720dd..3965540ad01 100644 --- a/java-client/barrage/src/main/java/io/deephaven/client/impl/BarrageSnapshotImpl.java +++ b/java-client/barrage/src/main/java/io/deephaven/client/impl/BarrageSnapshotImpl.java @@ -176,11 +176,6 @@ public void onCompleted() { } } - @Override - public TableDefinition getTableDefinition() { - return resultTable.getDefinition(); - } - @Override public Future entireTable() { return partialTable(null, null, false); diff --git a/java-client/barrage/src/main/java/io/deephaven/client/impl/BarrageSubscription.java b/java-client/barrage/src/main/java/io/deephaven/client/impl/BarrageSubscription.java index 3fe80623688..7fca15aa115 100644 --- a/java-client/barrage/src/main/java/io/deephaven/client/impl/BarrageSubscription.java +++ b/java-client/barrage/src/main/java/io/deephaven/client/impl/BarrageSubscription.java @@ -61,11 +61,6 @@ BarrageSubscription subscribe(TableSpec tableSpec, BarrageSubscriptionOptions op BarrageSubscription subscribe(TableHandle tableHandle, BarrageSubscriptionOptions options); } - /** - * @return the {@link TableDefinition} of the subscribed table - */ - TableDefinition getTableDefinition(); - /** * Request a full subscription of the data and populate a {@link Table} with the incrementally updating data that is * received. The returned future will block until all rows for the subscribed table are available. diff --git a/java-client/barrage/src/main/java/io/deephaven/client/impl/BarrageSubscriptionImpl.java b/java-client/barrage/src/main/java/io/deephaven/client/impl/BarrageSubscriptionImpl.java index 5ee5a8bb841..69d05206b16 100644 --- a/java-client/barrage/src/main/java/io/deephaven/client/impl/BarrageSubscriptionImpl.java +++ b/java-client/barrage/src/main/java/io/deephaven/client/impl/BarrageSubscriptionImpl.java @@ -170,11 +170,6 @@ public void onCompleted() { } } - @Override - public TableDefinition getTableDefinition() { - return resultTable.getDefinition(); - } - @Override public Future
entireTable() { return partialTable(null, null, false);