deephaven_enterprise.remote_table¶

Use the methods in this module to create reliable connections to remote Barrage tables. The tables gracefully handle disconnection and reconnect when the upstream is available.

To establish a subscription begin with in_local_cluster() and specify the name of the query and the table name to subscribe to. You can then call subscribe() or snapshot() on the result to fetch a live subscription or a static snapshot.

If you do not provide the prototype table definition, the query must be available and running to do the subscription or snapshot.

For example:

import deephaven_enterprise.remote_table ticking_remote_table = remote_table.in_local_cluster(query_name=”TestQuery”, table_name=”TestTable”) .subscribe(included_columns=[“Col1”, “Col3”, “Col5”])

for_remote_cluster(cluster_url)[source]¶

Create a new remote table builder for a remote cluster. If no table definition is provided the query must be available for connections.

Parameters:: cluster_url (str) – the url to the desired cluster
Returns:: a RemoteTableBuilder for the specified query and table

in_local_cluster(query_name, table_name, table_definition=None)[source]¶

Create a new remote table builder for the current cluster. If no table definition is provided the query must be available for connections.

Parameters:

query_name (str) – the name of the query to fetch the table from
table_name (str) – the table name
table_definition – (optional) the expected table definition.

Returns:

a RemoteTableBuilder for the specified query and table