Package io.deephaven.proto.backplane.grpc

Class TableServiceGrpc.TableServiceFutureStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractFutureStub<TableServiceGrpc.TableServiceFutureStub>

io.deephaven.proto.backplane.grpc.TableServiceGrpc.TableServiceFutureStub

Enclosing class:

TableServiceGrpc

public static final class TableServiceGrpc.TableServiceFutureStub
extends io.grpc.stub.AbstractFutureStub<TableServiceGrpc.TableServiceFutureStub>

A stub to allow clients to do ListenableFuture-style rpc calls to service TableService.

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method	Description
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	aggregate(AggregateRequest request)	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.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	aggregateAll(AggregateAllRequest request)	Aggregates all non-grouping columns against a single aggregation specification.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	ajTables(AjRajTablesRequest request)	Returns the result of an aj operation.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	applyPreviewColumns(ApplyPreviewColumnsRequest request)	Create a table that has preview columns applied to an existing source table.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	asOfJoinTables(AsOfJoinTablesRequest request)	Deprecated.
protected TableServiceGrpc.TableServiceFutureStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	comboAggregate(ComboAggregateRequest request)	Deprecated.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	computeColumnStatistics(ColumnStatisticsRequest request)	Returns a new table representing statistics about a single column of the provided table.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	createInputTable(CreateInputTableRequest request)	Creates a new Table based on the provided configuration.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	crossJoinTables(CrossJoinTablesRequest request)	Returns the result of a cross join operation.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	dropColumns(DropColumnsRequest request)	Drop columns from the parent table.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	emptyTable(EmptyTableRequest request)	Create an empty table with the given column names and types.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	exactJoinTables(ExactJoinTablesRequest request)	Returns the result of an exact join operation.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	fetchTable(FetchTableRequest request)	Fetches a Table from an existing source ticket and exports it to the local session result ticket.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	filter(FilterTableRequest request)	Filter parent table with structured filters.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	flatten(FlattenRequest request)	Returns a new table with a flattened row set.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	getExportedTableCreationResponse(Ticket request)	Request an ETCR for this ticket.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	head(HeadOrTailRequest request)	Extract rows from the head of the parent table.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	headBy(HeadOrTailByRequest request)	Run the headBy table operation for the given group by columns on the given table.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	lazyUpdate(SelectOrUpdateRequest request)	Add columns to the given table using the given column specifications and the lazyUpdate table operation.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	leftJoinTables(LeftJoinTablesRequest request)	Returns the result of a left join operation.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	mergeTables(MergeTablesRequest request)	Create a merged table from the given input tables.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	metaTable(MetaTableRequest request)	Returns the meta table of a table.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	multiJoinTables(MultiJoinTablesRequest request)	Returns the result of a multi-join operation.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	naturalJoinTables(NaturalJoinTablesRequest request)	Returns the result of a natural join operation.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	rajTables(AjRajTablesRequest request)	Returns the result of an raj operation.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	rangeJoinTables(RangeJoinTablesRequest request)	Returns the result of a range join operation.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	runChartDownsample(RunChartDownsampleRequest request)	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).
com.google.common.util.concurrent.ListenableFuture<SeekRowResponse>	seekRow(SeekRowRequest request)	Seek a row number within a table.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	select(SelectOrUpdateRequest request)	Select the given columns from the given table.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	selectDistinct(SelectDistinctRequest request)	Returns a new table definition with the unique tuples of the specified columns
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	snapshot(SnapshotTableRequest request)	Takes a single snapshot of the source_id table.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	snapshotWhen(SnapshotWhenTableRequest request)	Snapshot base_id, triggered by trigger_id, and export the resulting new table.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	sort(SortTableRequest request)	Sort parent table via the provide sort descriptors.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	tail(HeadOrTailRequest request)	Extract rows from the tail of the parent table.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	tailBy(HeadOrTailByRequest request)	Run the tailBy operation for the given group by columns on the given table.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	timeTable(TimeTableRequest request)	Create a time table with the given start time and period.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	ungroup(UngroupRequest request)	Ungroup the given columns (all columns will be ungrouped if columnsToUngroup is empty or unspecified).
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	unstructuredFilter(UnstructuredFilterTableRequest request)	Filter parent table with unstructured filters.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	update(SelectOrUpdateRequest request)	Add columns to the given table using the given column specifications and the update table operation.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	updateBy(UpdateByRequest request)	Returns the result of an updateBy table operation.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	updateView(SelectOrUpdateRequest request)	Add columns to the given table using the given column specifications and the updateView table operation.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	view(SelectOrUpdateRequest request)	Add columns to the given table using the given column specifications and the view table operation.
com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>	whereIn(WhereInRequest request)	Filters the left table based on the set of values in the right table.

Methods inherited from class io.grpc.stub.AbstractFutureStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReady

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

build

protected TableServiceGrpc.TableServiceFutureStub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<TableServiceGrpc.TableServiceFutureStub>

getExportedTableCreationResponse

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> getExportedTableCreationResponse(Ticket request)

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

fetchTable

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> fetchTable(FetchTableRequest request)

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

applyPreviewColumns

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> applyPreviewColumns(ApplyPreviewColumnsRequest request)

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

emptyTable

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> emptyTable(EmptyTableRequest request)

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

timeTable

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> timeTable(TimeTableRequest request)

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

dropColumns

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> dropColumns(DropColumnsRequest request)

 Drop columns from the parent table.
 

update

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> update(SelectOrUpdateRequest request)

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

lazyUpdate

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> lazyUpdate(SelectOrUpdateRequest request)

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

view

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> view(SelectOrUpdateRequest request)

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

updateView

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> updateView(SelectOrUpdateRequest request)

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

select

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> select(SelectOrUpdateRequest request)

 Select the given columns from the given table.
 

updateBy

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> updateBy(UpdateByRequest request)

 Returns the result of an updateBy table operation.
 

selectDistinct

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> selectDistinct(SelectDistinctRequest request)

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

filter

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> filter(FilterTableRequest request)

 Filter parent table with structured filters.
 

unstructuredFilter

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> unstructuredFilter(UnstructuredFilterTableRequest request)

 Filter parent table with unstructured filters.
 

sort

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> sort(SortTableRequest request)

 Sort parent table via the provide sort descriptors.
 

head

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> head(HeadOrTailRequest request)

 Extract rows from the head of the parent table.
 

tail

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> tail(HeadOrTailRequest request)

 Extract rows from the tail of the parent table.
 

headBy

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> headBy(HeadOrTailByRequest request)

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

tailBy

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> tailBy(HeadOrTailByRequest request)

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

ungroup

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> ungroup(UngroupRequest request)

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

mergeTables

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> mergeTables(MergeTablesRequest request)

 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 com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> crossJoinTables(CrossJoinTablesRequest request)

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

naturalJoinTables

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> naturalJoinTables(NaturalJoinTablesRequest request)

 Returns the result of a natural join operation.
 

exactJoinTables

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> exactJoinTables(ExactJoinTablesRequest request)

 Returns the result of an exact join operation.
 

leftJoinTables

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> leftJoinTables(LeftJoinTablesRequest request)

 Returns the result of a left join operation.
 

asOfJoinTables

@Deprecated
public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> asOfJoinTables(AsOfJoinTablesRequest request)

Deprecated.

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

ajTables

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> ajTables(AjRajTablesRequest request)

 Returns the result of an aj operation.
 

rajTables

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> rajTables(AjRajTablesRequest request)

 Returns the result of an raj operation.
 

multiJoinTables

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> multiJoinTables(MultiJoinTablesRequest request)

 Returns the result of a multi-join operation.
 

rangeJoinTables

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> rangeJoinTables(RangeJoinTablesRequest request)

 Returns the result of a range join operation.
 

comboAggregate

@Deprecated
public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> comboAggregate(ComboAggregateRequest request)

Deprecated.

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

aggregateAll

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> aggregateAll(AggregateAllRequest request)

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

aggregate

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> aggregate(AggregateRequest request)

 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 com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> snapshot(SnapshotTableRequest request)

 Takes a single snapshot of the source_id table.
 

snapshotWhen

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> snapshotWhen(SnapshotWhenTableRequest request)

 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 com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> flatten(FlattenRequest request)

 Returns a new table with a flattened row set.
 

runChartDownsample

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> runChartDownsample(RunChartDownsampleRequest request)

 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 com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> createInputTable(CreateInputTableRequest request)

 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 com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> whereIn(WhereInRequest request)

 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 com.google.common.util.concurrent.ListenableFuture<SeekRowResponse> seekRow(SeekRowRequest request)

 Seek a row number within a table.
 

metaTable

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> metaTable(MetaTableRequest request)

 Returns the meta table of a table.
 

computeColumnStatistics

public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> computeColumnStatistics(ColumnStatisticsRequest request)

 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.