java.lang.Object

io.deephaven.proto.backplane.grpc.TableServiceGrpc.TableServiceImplBase

io.deephaven.server.table.ops.TableServiceGrpcImpl

All Implemented Interfaces:: TableServiceGrpc.AsyncService, io.grpc.BindableService

public class TableServiceGrpcImpl extends TableServiceGrpc.TableServiceImplBase

Constructor Summary

Constructors

Constructor

Description

TableServiceGrpcImpl(TicketRouter ticketRouter, SessionService sessionService, TableServiceContextualAuthWiring authWiring, Map<BatchTableRequest.Operation.OpCase,GrpcTableOperation<?>> operationMap, ExportedTableUpdateListener.Factory exportedTableUpdateListenerFactory)
Method Summary

Modifier and Type

Method

Description

void

aggregate(@NotNull AggregateRequest request, @NotNull 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.

void

aggregateAll(@NotNull AggregateAllRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Aggregates all non-grouping columns against a single aggregation specification.

void

ajTables(@NotNull AjRajTablesRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Returns the result of an aj operation.

void

applyPreviewColumns(@NotNull ApplyPreviewColumnsRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Create a table that has preview columns applied to an existing source table.

void

asOfJoinTables(@NotNull AsOfJoinTablesRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Returns the result of an as of join operation.

void

batch(@NotNull BatchTableRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Batch a series of requests and send them all at once.

void

comboAggregate(@NotNull ComboAggregateRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Returns the result of an aggregate table operation.

void

computeColumnStatistics(@NotNull ColumnStatisticsRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Returns a new table representing statistics about a single column of the provided table.

void

createInputTable(@NotNull CreateInputTableRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Creates a new Table based on the provided configuration.

void

crossJoinTables(@NotNull CrossJoinTablesRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Returns the result of a cross join operation.

void

dropColumns(@NotNull DropColumnsRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Drop columns from the parent table.

void

emptyTable(@NotNull EmptyTableRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Create an empty table with the given column names and types.

void

exactJoinTables(@NotNull ExactJoinTablesRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Returns the result of an exact join operation.

void

exportedTableUpdates(@NotNull ExportedTableUpdatesRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableUpdateMessage> responseObserver)

Establish a stream of table updates for cheap notifications of table size updates.

void

fetchTable(@NotNull FetchTableRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Fetches a Table from an existing source ticket and exports it to the local session result ticket.

void

filter(@NotNull FilterTableRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Filter parent table with structured filters.

void

flatten(@NotNull FlattenRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Returns a new table with a flattened row set.

void

getExportedTableCreationResponse(@NotNull Ticket request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Request an ETCR for this ticket.

void

head(@NotNull HeadOrTailRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Extract rows from the head of the parent table.

void

headBy(@NotNull HeadOrTailByRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Run the headBy table operation for the given group by columns on the given table.

void

lazyUpdate(@NotNull SelectOrUpdateRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Add columns to the given table using the given column specifications and the lazyUpdate table operation.

void

leftJoinTables(@NotNull LeftJoinTablesRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Returns the result of a left join operation.

void

mergeTables(@NotNull MergeTablesRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Create a merged table from the given input tables.

void

metaTable(@NotNull MetaTableRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Returns the meta table of a table.

void

multiJoinTables(MultiJoinTablesRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Returns the result of a multi-join operation.

void

naturalJoinTables(@NotNull NaturalJoinTablesRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Returns the result of a natural join operation.

void

rajTables(@NotNull AjRajTablesRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Returns the result of an raj operation.

void

rangeJoinTables(@NotNull RangeJoinTablesRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Returns the result of a range join operation.

void

runChartDownsample(@NotNull RunChartDownsampleRequest request, @NotNull 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).

void

seekRow(@NotNull SeekRowRequest request, @NotNull io.grpc.stub.StreamObserver<SeekRowResponse> responseObserver)

Seek a row number within a table.

void

select(@NotNull SelectOrUpdateRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Select the given columns from the given table.

void

selectDistinct(@NotNull SelectDistinctRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Returns a new table definition with the unique tuples of the specified columns

void

slice(@NotNull SliceRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Returns a new table representing a sliced subset of the original table.

void

snapshot(@NotNull SnapshotTableRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Takes a single snapshot of the source_id table.

void

snapshotWhen(@NotNull SnapshotWhenTableRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Snapshot base_id, triggered by trigger_id, and export the resulting new table.

void

sort(@NotNull SortTableRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Sort parent table via the provide sort descriptors.

void

tail(@NotNull HeadOrTailRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Extract rows from the tail of the parent table.

void

tailBy(@NotNull HeadOrTailByRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Run the tailBy operation for the given group by columns on the given table.

void

timeTable(@NotNull TimeTableRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Create a time table with the given start time and period.

void

ungroup(@NotNull UngroupRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Ungroup the given columns (all columns will be ungrouped if columnsToUngroup is empty or unspecified).

void

unstructuredFilter(@NotNull UnstructuredFilterTableRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Filter parent table with unstructured filters.

void

update(@NotNull SelectOrUpdateRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Add columns to the given table using the given column specifications and the update table operation.

void

updateBy(@NotNull UpdateByRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Returns the result of an updateBy table operation.

void

updateView(@NotNull SelectOrUpdateRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Add columns to the given table using the given column specifications and the updateView table operation.

void

view(@NotNull SelectOrUpdateRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Add columns to the given table using the given column specifications and the view table operation.

void

whereIn(@NotNull WhereInRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Filters the left table based on the set of values in the right table.

Methods inherited from class io.deephaven.proto.backplane.grpc.TableServiceGrpc.TableServiceImplBase
bindService

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- TableServiceGrpcImpl
  
  @Inject public TableServiceGrpcImpl(TicketRouter ticketRouter, SessionService sessionService, TableServiceContextualAuthWiring authWiring, Map<BatchTableRequest.Operation.OpCase,GrpcTableOperation<?>> operationMap, ExportedTableUpdateListener.Factory exportedTableUpdateListenerFactory)
Method Details
- emptyTable
  
  public void emptyTable(@NotNull @NotNull EmptyTableRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Create an empty table with the given column names and types.
- timeTable
  
  public void timeTable(@NotNull @NotNull TimeTableRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Create a time table with the given start time and period.
- mergeTables
  
  public void mergeTables(@NotNull @NotNull MergeTablesRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  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.
- selectDistinct
  
  public void selectDistinct(@NotNull @NotNull SelectDistinctRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Returns a new table definition with the unique tuples of the specified columns
- update
  
  public void update(@NotNull @NotNull SelectOrUpdateRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Add columns to the given table using the given column specifications and the update table operation.
- lazyUpdate
  
  public void lazyUpdate(@NotNull @NotNull SelectOrUpdateRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Add columns to the given table using the given column specifications and the lazyUpdate table operation.
- view
  
  public void view(@NotNull @NotNull SelectOrUpdateRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Add columns to the given table using the given column specifications and the view table operation.
- updateView
  
  public void updateView(@NotNull @NotNull SelectOrUpdateRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Add columns to the given table using the given column specifications and the updateView table operation.
- select
  
  public void select(@NotNull @NotNull SelectOrUpdateRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Select the given columns from the given table.
- headBy
  
  public void headBy(@NotNull @NotNull HeadOrTailByRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Run the headBy table operation for the given group by columns on the given table.
- tailBy
  
  public void tailBy(@NotNull @NotNull HeadOrTailByRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Run the tailBy operation for the given group by columns on the given table.
- head
  
  public void head(@NotNull @NotNull HeadOrTailRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Extract rows from the head of the parent table.
- tail
  
  public void tail(@NotNull @NotNull HeadOrTailRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Extract rows from the tail of the parent table.
- ungroup
  
  public void ungroup(@NotNull @NotNull UngroupRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Ungroup the given columns (all columns will be ungrouped if columnsToUngroup is empty or unspecified).
- comboAggregate
  
  public void comboAggregate(@NotNull @NotNull ComboAggregateRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Returns the result of an aggregate table operation. Deprecated: Please use AggregateAll or Aggregate instead
- aggregateAll
  
  public void aggregateAll(@NotNull @NotNull AggregateAllRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Aggregates all non-grouping columns against a single aggregation specification.
- aggregate
  
  public void aggregate(@NotNull @NotNull AggregateRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  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(@NotNull @NotNull SnapshotTableRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Takes a single snapshot of the source_id table.
- snapshotWhen
  
  public void snapshotWhen(@NotNull @NotNull SnapshotWhenTableRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  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.
- dropColumns
  
  public void dropColumns(@NotNull @NotNull DropColumnsRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Drop columns from the parent table.
- filter
  
  public void filter(@NotNull @NotNull FilterTableRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Filter parent table with structured filters.
- unstructuredFilter
  
  public void unstructuredFilter(@NotNull @NotNull UnstructuredFilterTableRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Filter parent table with unstructured filters.
- sort
  
  public void sort(@NotNull @NotNull SortTableRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Sort parent table via the provide sort descriptors.
- flatten
  
  public void flatten(@NotNull @NotNull FlattenRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Returns a new table with a flattened row set.
- metaTable
  
  public void metaTable(@NotNull @NotNull MetaTableRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Returns the meta table of a table.
- crossJoinTables
  
  public void crossJoinTables(@NotNull @NotNull CrossJoinTablesRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Returns the result of a cross join operation. Also known as the cartesian product.
- naturalJoinTables
  
  public void naturalJoinTables(@NotNull @NotNull NaturalJoinTablesRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Returns the result of a natural join operation.
- exactJoinTables
  
  public void exactJoinTables(@NotNull @NotNull ExactJoinTablesRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Returns the result of an exact join operation.
- leftJoinTables
  
  public void leftJoinTables(@NotNull @NotNull LeftJoinTablesRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Returns the result of a left join operation.
- asOfJoinTables
  
  public void asOfJoinTables(@NotNull @NotNull AsOfJoinTablesRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Returns the result of an as of join operation. Deprecated: Please use AjTables or RajTables.
- ajTables
  
  public void ajTables(@NotNull @NotNull AjRajTablesRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Returns the result of an aj operation.
- rajTables
  
  public void rajTables(@NotNull @NotNull AjRajTablesRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Returns the result of an raj operation.
- multiJoinTables
  
  public void multiJoinTables(MultiJoinTablesRequest request, io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Returns the result of a multi-join operation.
- rangeJoinTables
  
  public void rangeJoinTables(@NotNull @NotNull RangeJoinTablesRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Returns the result of a range join operation.
- runChartDownsample
  
  public void runChartDownsample(@NotNull @NotNull RunChartDownsampleRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  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.
- fetchTable
  
  public void fetchTable(@NotNull @NotNull FetchTableRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Fetches a Table from an existing source ticket and exports it to the local session result ticket.
- applyPreviewColumns
  
  public void applyPreviewColumns(@NotNull @NotNull ApplyPreviewColumnsRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Create a table that has preview columns applied to an existing source table.
- createInputTable
  
  public void createInputTable(@NotNull @NotNull CreateInputTableRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  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.
- updateBy
  
  public void updateBy(@NotNull @NotNull UpdateByRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Returns the result of an updateBy table operation.
- slice
  
  public void slice(@NotNull @NotNull SliceRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  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.
- whereIn
  
  public void whereIn(@NotNull @NotNull WhereInRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  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.
- seekRow
  
  public void seekRow(@NotNull @NotNull SeekRowRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<SeekRowResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Seek a row number within a table.
- computeColumnStatistics
  
  public void computeColumnStatistics(@NotNull @NotNull ColumnStatisticsRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  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.
- batch
  
  public void batch(@NotNull @NotNull BatchTableRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  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(@NotNull @NotNull ExportedTableUpdatesRequest request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableUpdateMessage> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  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.
- getExportedTableCreationResponse
  
  public void getExportedTableCreationResponse(@NotNull @NotNull Ticket request, @NotNull @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)
  
  Description copied from interface: TableServiceGrpc.AsyncService
  Request an ETCR for this ticket. Ticket must reference a Table.

Class TableServiceGrpcImpl

Constructor Summary

Method Summary

Methods inherited from class io.deephaven.proto.backplane.grpc.TableServiceGrpc.TableServiceImplBase

Methods inherited from class java.lang.Object

Constructor Details

TableServiceGrpcImpl

Method Details

emptyTable

timeTable

mergeTables

selectDistinct

update

lazyUpdate

view

updateView

select

headBy

tailBy

head

tail

ungroup

comboAggregate

aggregateAll

aggregate

snapshot

snapshotWhen

dropColumns

filter

unstructuredFilter

sort

flatten

metaTable

crossJoinTables

naturalJoinTables

exactJoinTables

leftJoinTables

asOfJoinTables

ajTables

rajTables

multiJoinTables

rangeJoinTables

runChartDownsample

fetchTable

applyPreviewColumns

createInputTable

updateBy

slice

whereIn

seekRow

computeColumnStatistics

batch

exportedTableUpdates

getExportedTableCreationResponse