Package io.deephaven.server.table.ops

Class TableServiceGrpcImpl

java.lang.Object

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

io.deephaven.server.table.ops.TableServiceGrpcImpl

All Implemented Interfaces:

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	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 class: TableServiceGrpc.TableServiceImplBase

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

Overrides:

emptyTable in class TableServiceGrpc.TableServiceImplBase

timeTable

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

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

Overrides:

timeTable in class TableServiceGrpc.TableServiceImplBase

mergeTables

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 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.
 

Overrides:

mergeTables in class TableServiceGrpc.TableServiceImplBase

selectDistinct

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

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

Overrides:

selectDistinct in class TableServiceGrpc.TableServiceImplBase

update

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

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

Overrides:

update in class TableServiceGrpc.TableServiceImplBase

lazyUpdate

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

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

Overrides:

lazyUpdate in class TableServiceGrpc.TableServiceImplBase

view

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

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

Overrides:

view in class TableServiceGrpc.TableServiceImplBase

updateView

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

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

Overrides:

updateView in class TableServiceGrpc.TableServiceImplBase

select

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 Select the given columns from the given table.
 

Overrides:

select in class TableServiceGrpc.TableServiceImplBase

headBy

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

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

Overrides:

headBy in class TableServiceGrpc.TableServiceImplBase

tailBy

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

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

Overrides:

tailBy in class TableServiceGrpc.TableServiceImplBase

head

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 Extract rows from the head of the parent table.
 

Overrides:

head in class TableServiceGrpc.TableServiceImplBase

tail

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 Extract rows from the tail of the parent table.
 

Overrides:

tail in class TableServiceGrpc.TableServiceImplBase

ungroup

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

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

Overrides:

ungroup in class TableServiceGrpc.TableServiceImplBase

comboAggregate

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 Returns the result of an aggregate table operation.
 Deprecated: Please use AggregateAll or Aggregate instead
 

Overrides:

comboAggregate in class TableServiceGrpc.TableServiceImplBase

aggregateAll

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

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

Overrides:

aggregateAll in class TableServiceGrpc.TableServiceImplBase

aggregate

public void aggregate(@NotNull
 @NotNull AggregateRequest request,
 @NotNull
 @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Description copied from class: TableServiceGrpc.TableServiceImplBase

 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.
 

Overrides:

aggregate in class TableServiceGrpc.TableServiceImplBase

snapshot

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 Takes a single snapshot of the source_id table.
 

Overrides:

snapshot in class TableServiceGrpc.TableServiceImplBase

snapshotWhen

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 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.
 

Overrides:

snapshotWhen in class TableServiceGrpc.TableServiceImplBase

dropColumns

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 Drop columns from the parent table.
 

Overrides:

dropColumns in class TableServiceGrpc.TableServiceImplBase

filter

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 Filter parent table with structured filters.
 

Overrides:

filter in class TableServiceGrpc.TableServiceImplBase

unstructuredFilter

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 Filter parent table with unstructured filters.
 

Overrides:

unstructuredFilter in class TableServiceGrpc.TableServiceImplBase

sort

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 Sort parent table via the provide sort descriptors.
 

Overrides:

sort in class TableServiceGrpc.TableServiceImplBase

flatten

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 Returns a new table with a flattened row set.
 

Overrides:

flatten in class TableServiceGrpc.TableServiceImplBase

metaTable

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 Returns the meta table of a table.
 

Overrides:

metaTable in class TableServiceGrpc.TableServiceImplBase

crossJoinTables

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 Returns the result of a cross join operation. Also known as the cartesian product.
 

Overrides:

crossJoinTables in class TableServiceGrpc.TableServiceImplBase

naturalJoinTables

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 Returns the result of a natural join operation.
 

Overrides:

naturalJoinTables in class TableServiceGrpc.TableServiceImplBase

exactJoinTables

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 Returns the result of an exact join operation.
 

Overrides:

exactJoinTables in class TableServiceGrpc.TableServiceImplBase

leftJoinTables

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 Returns the result of a left join operation.
 

Overrides:

leftJoinTables in class TableServiceGrpc.TableServiceImplBase

asOfJoinTables

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 Returns the result of an as of join operation.
 Deprecated: Please use AjTables or RajTables.
 

Overrides:

asOfJoinTables in class TableServiceGrpc.TableServiceImplBase

ajTables

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 Returns the result of an aj operation.
 

Overrides:

ajTables in class TableServiceGrpc.TableServiceImplBase

rajTables

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 Returns the result of an raj operation.
 

Overrides:

rajTables in class TableServiceGrpc.TableServiceImplBase

multiJoinTables

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 Returns the result of a multi-join operation.
 

Overrides:

multiJoinTables in class TableServiceGrpc.TableServiceImplBase

rangeJoinTables

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 Returns the result of a range join operation.
 

Overrides:

rangeJoinTables in class TableServiceGrpc.TableServiceImplBase

runChartDownsample

public void runChartDownsample(@NotNull
 @NotNull RunChartDownsampleRequest request,
 @NotNull
 @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)

Description copied from class: TableServiceGrpc.TableServiceImplBase

 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.
 

Overrides:

runChartDownsample in class TableServiceGrpc.TableServiceImplBase

fetchTable

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

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

Overrides:

fetchTable in class TableServiceGrpc.TableServiceImplBase

applyPreviewColumns

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

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

Overrides:

applyPreviewColumns in class TableServiceGrpc.TableServiceImplBase

createInputTable

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 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.
 

Overrides:

createInputTable in class TableServiceGrpc.TableServiceImplBase

updateBy

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 Returns the result of an updateBy table operation.
 

Overrides:

updateBy in class TableServiceGrpc.TableServiceImplBase

whereIn

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 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.
 

Overrides:

whereIn in class TableServiceGrpc.TableServiceImplBase

seekRow

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 Seek a row number within a table.
 

Overrides:

seekRow in class TableServiceGrpc.TableServiceImplBase

computeColumnStatistics

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 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.
 

Overrides:

computeColumnStatistics in class TableServiceGrpc.TableServiceImplBase

batch

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 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.
 

Overrides:

batch in class TableServiceGrpc.TableServiceImplBase

exportedTableUpdates

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 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.
 

Overrides:

exportedTableUpdates in class TableServiceGrpc.TableServiceImplBase

getExportedTableCreationResponse

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

Description copied from class: TableServiceGrpc.TableServiceImplBase

 Request an ETCR for this ticket. Ticket must reference a Table.
 

Overrides:

getExportedTableCreationResponse in class TableServiceGrpc.TableServiceImplBase