From ec48404539045730cce68e518a54df5c7654a2d4 Mon Sep 17 00:00:00 2001 From: georgecwan Date: Thu, 30 Nov 2023 10:25:34 -0800 Subject: [PATCH] Fix formatting --- .../web/client/api/JsPartitionedTable.java | 70 +++++++++---------- 1 file changed, 35 insertions(+), 35 deletions(-) diff --git a/web/client-api/src/main/java/io/deephaven/web/client/api/JsPartitionedTable.java b/web/client-api/src/main/java/io/deephaven/web/client/api/JsPartitionedTable.java index 9370a1ae6bb..897e616ebc5 100644 --- a/web/client-api/src/main/java/io/deephaven/web/client/api/JsPartitionedTable.java +++ b/web/client-api/src/main/java/io/deephaven/web/client/api/JsPartitionedTable.java @@ -47,10 +47,10 @@ public class JsPartitionedTable extends HasLifecycle implements ServerObject { public static final String EVENT_KEYADDED = "keyadded", EVENT_DISCONNECT = JsTable.EVENT_DISCONNECT, EVENT_RECONNECT = JsTable.EVENT_RECONNECT, - /** - * Indicates that an error has occurred while communicating with the server. - */ - EVENT_RECONNECTFAILED = JsTable.EVENT_RECONNECTFAILED; + /** + * Indicates that an error has occurred while communicating with the server. + */ + EVENT_RECONNECTFAILED = JsTable.EVENT_RECONNECTFAILED; private final WorkerConnection connection; private final JsWidget widget; @@ -169,26 +169,26 @@ private void populateLazyTable(List key) { tables.put(key, JsLazy.of(() -> { // If we've entered this lambda, the JsLazy is being used, so we need to go ahead and get the tablehandle final ClientTableState entry = connection.newState((c, cts, metadata) -> { - // TODO deephaven-core#2529 parallelize this - connection.newTable( - descriptor.getKeyColumnNamesList().asArray(new String[0]), - keyColumnTypes.toArray(new String[0]), - key.stream().map(item -> new Object[]{item}).toArray(Object[][]::new), - null, - this) - .then(table -> { - GetTableRequest getTableRequest = new GetTableRequest(); - getTableRequest.setPartitionedTable(widget.getTicket()); - getTableRequest.setKeyTableTicket(table.getHandle().makeTicket()); - getTableRequest.setResultId(cts.getHandle().makeTicket()); - connection.partitionedTableServiceClient().getTable(getTableRequest, connection.metadata(), - (error, success) -> { - table.close(); - c.apply(error, success); - }); - return null; - }); - }, + // TODO deephaven-core#2529 parallelize this + connection.newTable( + descriptor.getKeyColumnNamesList().asArray(new String[0]), + keyColumnTypes.toArray(new String[0]), + key.stream().map(item -> new Object[] {item}).toArray(Object[][]::new), + null, + this) + .then(table -> { + GetTableRequest getTableRequest = new GetTableRequest(); + getTableRequest.setPartitionedTable(widget.getTicket()); + getTableRequest.setKeyTableTicket(table.getHandle().makeTicket()); + getTableRequest.setResultId(cts.getHandle().makeTicket()); + connection.partitionedTableServiceClient().getTable(getTableRequest, connection.metadata(), + (error, success) -> { + table.close(); + c.apply(error, success); + }); + return null; + }); + }, "partitioned table key " + key); // later, when the CTS is released, remove this "table" from the map and replace with an unresolved JsLazy @@ -232,11 +232,11 @@ public Promise getTable(Object key) { */ public Promise getMergedTable() { return connection.newState((c, cts, metadata) -> { - MergeRequest requestMessage = new MergeRequest(); - requestMessage.setPartitionedTable(widget.getTicket()); - requestMessage.setResultId(cts.getHandle().makeTicket()); - connection.partitionedTableServiceClient().merge(requestMessage, connection.metadata(), c::apply); - }, "partitioned table merged table") + MergeRequest requestMessage = new MergeRequest(); + requestMessage.setPartitionedTable(widget.getTicket()); + requestMessage.setResultId(cts.getHandle().makeTicket()); + connection.partitionedTableServiceClient().merge(requestMessage, connection.metadata(), c::apply); + }, "partitioned table merged table") .refetch(this, connection.metadata()) .then(cts -> Promise.resolve(new JsTable(cts.getConnection(), cts))); } @@ -293,12 +293,12 @@ public Column[] getColumns() { @JsMethod public Promise getKeyTable() { return connection.newState((c, state, metadata) -> { - DropColumnsRequest drop = new DropColumnsRequest(); - drop.setColumnNamesList(new String[]{descriptor.getConstituentColumnName()}); - drop.setSourceId(keys.state().getHandle().makeTableReference()); - drop.setResultId(state.getHandle().makeTicket()); - connection.tableServiceClient().dropColumns(drop, metadata, c::apply); - }, "drop constituent column") + DropColumnsRequest drop = new DropColumnsRequest(); + drop.setColumnNamesList(new String[] {descriptor.getConstituentColumnName()}); + drop.setSourceId(keys.state().getHandle().makeTableReference()); + drop.setResultId(state.getHandle().makeTicket()); + connection.tableServiceClient().dropColumns(drop, metadata, c::apply); + }, "drop constituent column") .refetch(this, connection.metadata()) .then(state -> Promise.resolve(new JsTable(connection, state))); }