Package io.deephaven.proto.backplane.grpc

Class TableServiceGrpc.TableServiceBlockingV2Stub

java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractBlockingStub<TableServiceGrpc.TableServiceBlockingV2Stub>
io.deephaven.proto.backplane.grpc.TableServiceGrpc.TableServiceBlockingV2Stub
Enclosing class:
TableServiceGrpc
public static final class TableServiceGrpc.TableServiceBlockingV2Stub extends io.grpc.stub.AbstractBlockingStub<TableServiceGrpc.TableServiceBlockingV2Stub>
A stub to allow clients to do synchronous rpc calls to service TableService.

  • Method Details

    • build

      protected TableServiceGrpc.TableServiceBlockingV2Stub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
      Specified by:
      build in class io.grpc.stub.AbstractStub<TableServiceGrpc.TableServiceBlockingV2Stub>

    • getExportedTableCreationResponse

      public ExportedTableCreationResponse getExportedTableCreationResponse(Ticket request) throws io.grpc.StatusException
       Request an ETCR for this ticket. Ticket must reference a Table.
      Throws:
      io.grpc.StatusException

    • fetchTable

      public ExportedTableCreationResponse fetchTable(FetchTableRequest request) throws io.grpc.StatusException
       Fetches a Table from an existing source ticket and exports it to the local session result ticket.
      Throws:
      io.grpc.StatusException

    • applyPreviewColumns

      public ExportedTableCreationResponse applyPreviewColumns(ApplyPreviewColumnsRequest request) throws io.grpc.StatusException
       Create a table that has preview columns applied to an existing source table.
      Throws:
      io.grpc.StatusException

    • emptyTable

      public ExportedTableCreationResponse emptyTable(EmptyTableRequest request) throws io.grpc.StatusException
       Create an empty table with the given column names and types.
      Throws:
      io.grpc.StatusException

    • timeTable

      public ExportedTableCreationResponse timeTable(TimeTableRequest request) throws io.grpc.StatusException
       Create a time table with the given start time and period.
      Throws:
      io.grpc.StatusException

    • dropColumns

      public ExportedTableCreationResponse dropColumns(DropColumnsRequest request) throws io.grpc.StatusException
       Drop columns from the parent table.
      Throws:
      io.grpc.StatusException

    • update

      public ExportedTableCreationResponse update(SelectOrUpdateRequest request) throws io.grpc.StatusException
       Add columns to the given table using the given column specifications and the update table operation.
      Throws:
      io.grpc.StatusException

    • lazyUpdate

      public ExportedTableCreationResponse lazyUpdate(SelectOrUpdateRequest request) throws io.grpc.StatusException
       Add columns to the given table using the given column specifications and the lazyUpdate table operation.
      Throws:
      io.grpc.StatusException

    • view

      public ExportedTableCreationResponse view(SelectOrUpdateRequest request) throws io.grpc.StatusException
       Add columns to the given table using the given column specifications and the view table operation.
      Throws:
      io.grpc.StatusException

    • updateView

      public ExportedTableCreationResponse updateView(SelectOrUpdateRequest request) throws io.grpc.StatusException
       Add columns to the given table using the given column specifications and the updateView table operation.
      Throws:
      io.grpc.StatusException

    • select

      public ExportedTableCreationResponse select(SelectOrUpdateRequest request) throws io.grpc.StatusException
       Select the given columns from the given table.
      Throws:
      io.grpc.StatusException

    • updateBy

      public ExportedTableCreationResponse updateBy(UpdateByRequest request) throws io.grpc.StatusException
       Returns the result of an updateBy table operation.
      Throws:
      io.grpc.StatusException

    • selectDistinct

      public ExportedTableCreationResponse selectDistinct(SelectDistinctRequest request) throws io.grpc.StatusException
       Returns a new table definition with the unique tuples of the specified columns
      Throws:
      io.grpc.StatusException

    • filter

      public ExportedTableCreationResponse filter(FilterTableRequest request) throws io.grpc.StatusException
       Filter parent table with structured filters.
      Throws:
      io.grpc.StatusException

    • unstructuredFilter

      public ExportedTableCreationResponse unstructuredFilter(UnstructuredFilterTableRequest request) throws io.grpc.StatusException
       Filter parent table with unstructured filters.
      Throws:
      io.grpc.StatusException

    • sort

      public ExportedTableCreationResponse sort(SortTableRequest request) throws io.grpc.StatusException
       Sort parent table via the provide sort descriptors.
      Throws:
      io.grpc.StatusException

    • head

      public ExportedTableCreationResponse head(HeadOrTailRequest request) throws io.grpc.StatusException
       Extract rows from the head of the parent table.
      Throws:
      io.grpc.StatusException

    • tail

      public ExportedTableCreationResponse tail(HeadOrTailRequest request) throws io.grpc.StatusException
       Extract rows from the tail of the parent table.
      Throws:
      io.grpc.StatusException

    • headBy

      public ExportedTableCreationResponse headBy(HeadOrTailByRequest request) throws io.grpc.StatusException
       Run the headBy table operation for the given group by columns on the given table.
      Throws:
      io.grpc.StatusException

    • tailBy

      public ExportedTableCreationResponse tailBy(HeadOrTailByRequest request) throws io.grpc.StatusException
       Run the tailBy operation for the given group by columns on the given table.
      Throws:
      io.grpc.StatusException

    • ungroup

      public ExportedTableCreationResponse ungroup(UngroupRequest request) throws io.grpc.StatusException
       Ungroup the given columns (all columns will be ungrouped if columnsToUngroup is empty or unspecified).
      Throws:
      io.grpc.StatusException

    • mergeTables

      public ExportedTableCreationResponse mergeTables(MergeTablesRequest request) throws io.grpc.StatusException
       Create a merged table from the given input tables. If a key column is provided (not null), a sorted
 merged will be performed using that column.
      Throws:
      io.grpc.StatusException

    • crossJoinTables

      public ExportedTableCreationResponse crossJoinTables(CrossJoinTablesRequest request) throws io.grpc.StatusException
       Returns the result of a cross join operation. Also known as the cartesian product.
      Throws:
      io.grpc.StatusException

    • naturalJoinTables

      public ExportedTableCreationResponse naturalJoinTables(NaturalJoinTablesRequest request) throws io.grpc.StatusException
       Returns the result of a natural join operation.
      Throws:
      io.grpc.StatusException

    • exactJoinTables

      public ExportedTableCreationResponse exactJoinTables(ExactJoinTablesRequest request) throws io.grpc.StatusException
       Returns the result of an exact join operation.
      Throws:
      io.grpc.StatusException

    • leftJoinTables

      public ExportedTableCreationResponse leftJoinTables(LeftJoinTablesRequest request) throws io.grpc.StatusException
       Returns the result of a left join operation.
      Throws:
      io.grpc.StatusException

    • asOfJoinTables

      @Deprecated public ExportedTableCreationResponse asOfJoinTables(AsOfJoinTablesRequest request) throws io.grpc.StatusException
      Deprecated.
       Returns the result of an as of join operation.
 Deprecated: Please use AjTables or RajTables.
      Throws:
      io.grpc.StatusException

    • ajTables

      public ExportedTableCreationResponse ajTables(AjRajTablesRequest request) throws io.grpc.StatusException
       Returns the result of an aj operation.
      Throws:
      io.grpc.StatusException

    • rajTables

      public ExportedTableCreationResponse rajTables(AjRajTablesRequest request) throws io.grpc.StatusException
       Returns the result of an raj operation.
      Throws:
      io.grpc.StatusException

    • multiJoinTables

      public ExportedTableCreationResponse multiJoinTables(MultiJoinTablesRequest request) throws io.grpc.StatusException
       Returns the result of a multi-join operation.
      Throws:
      io.grpc.StatusException

    • rangeJoinTables

      public ExportedTableCreationResponse rangeJoinTables(RangeJoinTablesRequest request) throws io.grpc.StatusException
       Returns the result of a range join operation.
      Throws:
      io.grpc.StatusException

    • comboAggregate

      @Deprecated public ExportedTableCreationResponse comboAggregate(ComboAggregateRequest request) throws io.grpc.StatusException
      Deprecated.
       Returns the result of an aggregate table operation.
 Deprecated: Please use AggregateAll or Aggregate instead
      Throws:
      io.grpc.StatusException

    • aggregateAll

      public ExportedTableCreationResponse aggregateAll(AggregateAllRequest request) throws io.grpc.StatusException
       Aggregates all non-grouping columns against a single aggregation specification.
      Throws:
      io.grpc.StatusException

    • aggregate

      public ExportedTableCreationResponse aggregate(AggregateRequest request) throws io.grpc.StatusException
       Produce an aggregated result by grouping the source_id table according to the group_by_columns and applying
 aggregations to each resulting group of rows. The result table will have one row per group, ordered by
 the encounter order within the source_id table, thereby ensuring that the row key for a given group never
 changes.
      Throws:
      io.grpc.StatusException

    • snapshot

      public ExportedTableCreationResponse snapshot(SnapshotTableRequest request) throws io.grpc.StatusException
       Takes a single snapshot of the source_id table.
      Throws:
      io.grpc.StatusException

    • snapshotWhen

      public ExportedTableCreationResponse snapshotWhen(SnapshotWhenTableRequest request) throws io.grpc.StatusException
       Snapshot base_id, triggered by trigger_id, and export the resulting new table.
 The trigger_id table's change events cause a new snapshot to be taken. The result table includes a
 "snapshot key" which is a subset (possibly all) of the base_id table's columns. The
 remaining columns in the result table come from base_id table, the table being snapshotted.
      Throws:
      io.grpc.StatusException

    • flatten

      public ExportedTableCreationResponse flatten(FlattenRequest request) throws io.grpc.StatusException
       Returns a new table with a flattened row set.
      Throws:
      io.grpc.StatusException

    • runChartDownsample

      public ExportedTableCreationResponse runChartDownsample(RunChartDownsampleRequest request) throws io.grpc.StatusException
      
 Downsamples a table assume its contents will be rendered in a run chart, with each subsequent row holding a later
 X value (i.e., sorted on that column). Multiple Y columns can be specified, as can a range of values for the X
 column to support zooming in.
      Throws:
      io.grpc.StatusException

    • createInputTable

      public ExportedTableCreationResponse createInputTable(CreateInputTableRequest request) throws io.grpc.StatusException
      
 Creates a new Table based on the provided configuration. This can be used as a regular table from the other methods
 in this interface, or can be interacted with via the InputTableService to modify its contents.
      Throws:
      io.grpc.StatusException

    • whereIn

      public ExportedTableCreationResponse whereIn(WhereInRequest request) throws io.grpc.StatusException
      
 Filters the left table based on the set of values in the right table.
 Note that when the right table ticks, all of the rows in the left table are going to be re-evaluated,
 thus the intention is that the right table is fairly slow moving compared with the left table.
      Throws:
      io.grpc.StatusException

    • batch

      @ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918") public io.grpc.stub.BlockingClientCall<?,ExportedTableCreationResponse> batch(BatchTableRequest request)
       Batch a series of requests and send them all at once. This enables the user to create intermediate tables without
 requiring them to be exported and managed by the client. The server will automatically release any tables when they
 are no longer depended upon.

    • exportedTableUpdates

      @ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918") public io.grpc.stub.BlockingClientCall<?,ExportedTableUpdateMessage> exportedTableUpdates(ExportedTableUpdatesRequest request)
       Establish a stream of table updates for cheap notifications of table size updates.
 New streams will flush updates for all existing table exports. An export id of zero will be sent to indicate all
 exports have sent their refresh update. Table updates may be intermingled with initial refresh updates after their
 initial update had been sent.

    • seekRow

      public SeekRowResponse seekRow(SeekRowRequest request) throws io.grpc.StatusException
       Seek a row number within a table.
      Throws:
      io.grpc.StatusException

    • metaTable

      public ExportedTableCreationResponse metaTable(MetaTableRequest request) throws io.grpc.StatusException
       Returns the meta table of a table.
      Throws:
      io.grpc.StatusException

    • computeColumnStatistics

      public ExportedTableCreationResponse computeColumnStatistics(ColumnStatisticsRequest request) throws io.grpc.StatusException
      
 Returns a new table representing statistics about a single column of the provided table. This
 result table will be static - use Aggregation() instead for updating results. Presently, the
 primary use case for this is the Deephaven Web UI.
      Throws:
      io.grpc.StatusException

    • slice

      public ExportedTableCreationResponse slice(SliceRequest request) throws io.grpc.StatusException
      
 Returns a new table representing a sliced subset of the original table. The start position is inclusive
 and the end position is exclusive. If a negative value is given, then the position is counted from the end of
 the table.
      Throws:
      io.grpc.StatusException