Package io.deephaven.proto.backplane.grpc

Interface TableServiceGrpc.AsyncService

All Known Implementing Classes:
TableServiceGrpc.TableServiceImplBase, TableServiceGrpcImpl
Enclosing class:
TableServiceGrpc
public static interface TableServiceGrpc.AsyncService

  • Method Details

    • getExportedTableCreationResponse

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

    • fetchTable

      default 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

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

    • emptyTable

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

    • timeTable

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

    • dropColumns

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

    • update

      default 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

      default 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

      default 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

      default 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

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

    • updateBy

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

    • selectDistinct

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

    • filter

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

    • unstructuredFilter

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

    • sort

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

    • head

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

    • tail

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

    • headBy

      default 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

      default 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

      default 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

      default 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

      default 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

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

    • exactJoinTables

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

    • leftJoinTables

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

    • asOfJoinTables

      @Deprecated default 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

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

    • rajTables

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

    • multiJoinTables

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

    • rangeJoinTables

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

    • comboAggregate

      @Deprecated default 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

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

    • aggregate

      default 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

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

    • snapshotWhen

      default 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

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

    • runChartDownsample

      default 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

      default 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

      default 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

      default 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

      default 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

      default void seekRow(SeekRowRequest request, io.grpc.stub.StreamObserver<SeekRowResponse> responseObserver)
       Seek a row number within a table.

    • metaTable

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

    • computeColumnStatistics

      default 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.

    • slice

      default void slice(SliceRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
      
 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.