Package io.deephaven.proto.backplane.grpc

Class TableServiceGrpc.TableServiceStub

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

  • Method Details

    • build

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

    • getExportedTableCreationResponse

      public void getExportedTableCreationResponse(Ticket request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Request an ETCR for this ticket. Ticket must reference a Table.

    • fetchTable

      public void fetchTable(FetchTableRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Fetches a Table from an existing source ticket and exports it to the local session result ticket.

    • applyPreviewColumns

      public void applyPreviewColumns(ApplyPreviewColumnsRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Create a table that has preview columns applied to an existing source table.

    • emptyTable

      public void emptyTable(EmptyTableRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Create an empty table with the given column names and types.

    • timeTable

      public void timeTable(TimeTableRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Create a time table with the given start time and period.

    • dropColumns

      public void dropColumns(DropColumnsRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Drop columns from the parent table.

    • update

      public void update(SelectOrUpdateRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Add columns to the given table using the given column specifications and the update table operation.

    • lazyUpdate

      public void lazyUpdate(SelectOrUpdateRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Add columns to the given table using the given column specifications and the lazyUpdate table operation.

    • view

      public void view(SelectOrUpdateRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Add columns to the given table using the given column specifications and the view table operation.

    • updateView

      public void updateView(SelectOrUpdateRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Add columns to the given table using the given column specifications and the updateView table operation.

    • select

      public void select(SelectOrUpdateRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Select the given columns from the given table.

    • updateBy

      public void updateBy(UpdateByRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Returns the result of an updateBy table operation.

    • selectDistinct

      public void selectDistinct(SelectDistinctRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Returns a new table definition with the unique tuples of the specified columns

    • filter

      public void filter(FilterTableRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Filter parent table with structured filters.

    • unstructuredFilter

      public void unstructuredFilter(UnstructuredFilterTableRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Filter parent table with unstructured filters.

    • sort

      public void sort(SortTableRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Sort parent table via the provide sort descriptors.

    • head

      public void head(HeadOrTailRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Extract rows from the head of the parent table.

    • tail

      public void tail(HeadOrTailRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Extract rows from the tail of the parent table.

    • headBy

      public void headBy(HeadOrTailByRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Run the headBy table operation for the given group by columns on the given table.

    • tailBy

      public void tailBy(HeadOrTailByRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Run the tailBy operation for the given group by columns on the given table.

    • ungroup

      public void ungroup(UngroupRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Ungroup the given columns (all columns will be ungrouped if columnsToUngroup is empty or unspecified).

    • mergeTables

      public void mergeTables(MergeTablesRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       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.

    • crossJoinTables

      public void crossJoinTables(CrossJoinTablesRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Returns the result of a cross join operation. Also known as the cartesian product.

    • naturalJoinTables

      public void naturalJoinTables(NaturalJoinTablesRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Returns the result of a natural join operation.

    • exactJoinTables

      public void exactJoinTables(ExactJoinTablesRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Returns the result of an exact join operation.

    • leftJoinTables

      public void leftJoinTables(LeftJoinTablesRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Returns the result of a left join operation.

    • asOfJoinTables

      @Deprecated public void asOfJoinTables(AsOfJoinTablesRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
      Deprecated.
       Returns the result of an as of join operation.
 Deprecated: Please use AjTables or RajTables.

    • ajTables

      public void ajTables(AjRajTablesRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Returns the result of an aj operation.

    • rajTables

      public void rajTables(AjRajTablesRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Returns the result of an raj operation.

    • multiJoinTables

      public void multiJoinTables(MultiJoinTablesRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Returns the result of a multi-join operation.

    • rangeJoinTables

      public void rangeJoinTables(RangeJoinTablesRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Returns the result of a range join operation.

    • comboAggregate

      @Deprecated public void comboAggregate(ComboAggregateRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
      Deprecated.
       Returns the result of an aggregate table operation.
 Deprecated: Please use AggregateAll or Aggregate instead

    • aggregateAll

      public void aggregateAll(AggregateAllRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Aggregates all non-grouping columns against a single aggregation specification.

    • aggregate

      public void aggregate(AggregateRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       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.

    • snapshot

      public void snapshot(SnapshotTableRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Takes a single snapshot of the source_id table.

    • snapshotWhen

      public void snapshotWhen(SnapshotWhenTableRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       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.

    • flatten

      public void flatten(FlattenRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Returns a new table with a flattened row set.

    • runChartDownsample

      public void runChartDownsample(RunChartDownsampleRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
      
 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.

    • createInputTable

      public void createInputTable(CreateInputTableRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
      
 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.

    • whereIn

      public void whereIn(WhereInRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
      
 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.

    • batch

      public void batch(BatchTableRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       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

      public void exportedTableUpdates(ExportedTableUpdatesRequest request, io.grpc.stub.StreamObserver<ExportedTableUpdateMessage> responseObserver)
       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 void seekRow(SeekRowRequest request, io.grpc.stub.StreamObserver<SeekRowResponse> responseObserver)
       Seek a row number within a table.

    • metaTable

      public void metaTable(MetaTableRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
       Returns the meta table of a table.

    • computeColumnStatistics

      public void computeColumnStatistics(ColumnStatisticsRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
      
 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.