Package io.deephaven.client.impl

Interface BarrageSubscription

All Known Implementing Classes:
BarrageSubscriptionImpl
public interface BarrageSubscription
A BarrageSubscription represents a subscription over a table that may or may not be filtered to a viewport of the remote source table.

  • Method Details

    • make

      static BarrageSubscription make(BarrageSession session, ScheduledExecutorService executorService, TableHandle tableHandle, BarrageSubscriptionOptions options)
      Create a BarrageSubscription from a TableHandle.
      Parameters:
      session - the Deephaven session that this export belongs to
      executorService - an executor service used to flush stats
      tableHandle - the tableHandle to subscribe to (ownership is transferred to the subscription)
      options - the transport level options for this subscription
      Returns:
      a BarrageSubscription from a TableHandle

    • entireTable

      Future<Table> entireTable()
      Request a full subscription of the data and populate a Table with the incrementally updating data that is received. The returned future will block until all rows for the subscribed table are available.
      Returns:
      a Future that will be populated with the result Table

    • partialTable

      Future<Table> partialTable(RowSet viewport, BitSet columns)
      Request a partial subscription of the data limited by viewport or column set and populate a Table with the data that is received. The returned future will block until the subscribed table viewport is satisfied.
      Parameters:
      viewport - the position-space viewport to use for the subscription
      columns - the columns to include in the subscription
      Returns:
      a Future that will be populated with the result Table

    • partialTable

      Future<Table> partialTable(RowSet viewport, BitSet columns, boolean reverseViewport)
      Request a partial subscription of the data limited by viewport or column set and populate a Table with the data that is received. Allows the viewport to be reversed. The returned future will block until the subscribed table viewport is satisfied.
      Parameters:
      viewport - the position-space viewport to use for the subscription
      columns - the columns to include in the subscription
      reverseViewport - Whether to treat posRowSet as offsets from LongSizedDataStructure.size() rather than 0
      Returns:
      a Future that will be populated with the result Table

    • snapshotEntireTable

      Future<Table> snapshotEntireTable()
      Request a full snapshot of the data and populate a Table with the incrementally updating data that is received. The returned future will block until all rows for the snapshot table are available.
      Returns:
      a Future that will be populated with the result Table

    • snapshotPartialTable

      Future<Table> snapshotPartialTable(RowSet viewport, BitSet columns)
      Request a partial snapshot of the data limited by viewport or column set and populate a Table with the data that is received. The returned future will block until the snapshot table viewport is satisfied.
      Parameters:
      viewport - the position-space viewport to use for the subscription
      columns - the columns to include in the subscription
      Returns:
      a Future that will be populated with the result Table

    • snapshotPartialTable

      Future<Table> snapshotPartialTable(RowSet viewport, BitSet columns, boolean reverseViewport)
      Request a partial snapshot of the data limited by viewport or column set and populate a Table with the data that is received. Allows the viewport to be reversed. The returned future will block until the snapshot table viewport is satisfied.
      Parameters:
      viewport - the position-space viewport to use for the subscription
      columns - the columns to include in the subscription
      reverseViewport - Whether to treat posRowSet as offsets from LongSizedDataStructure.size() rather than 0
      Returns:
      a Future that will be populated with the result Table