Package io.deephaven.server.partitionedtable

Class PartitionedTableServiceGrpcImpl

java.lang.Object

io.deephaven.proto.backplane.grpc.PartitionedTableServiceGrpc.PartitionedTableServiceImplBase

io.deephaven.server.partitionedtable.PartitionedTableServiceGrpcImpl

All Implemented Interfaces:

PartitionedTableServiceGrpc.AsyncService, io.grpc.BindableService

public class PartitionedTableServiceGrpcImpl
extends PartitionedTableServiceGrpc.PartitionedTableServiceImplBase

Constructor Summary

Constructors

Constructor	Description
PartitionedTableServiceGrpcImpl(TicketRouter ticketRouter, SessionService sessionService, AuthorizationProvider authorizationProvider, PartitionedTableServiceContextualAuthWiring authWiring)

Method Summary

Modifier and Type	Method	Description
void	getTable(@NotNull GetTableRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)	Given a partitioned table and a row described by another table's contents, returns a table that matched that row, if any.
void	merge(@NotNull MergeRequest request, @NotNull io.grpc.stub.StreamObserver<ExportedTableCreationResponse> responseObserver)	Given a partitioned table, returns a table with the contents of all of the constituent tables.
void	partitionBy(@NotNull PartitionByRequest request, @NotNull io.grpc.stub.StreamObserver<PartitionByResponse> responseObserver)	Transforms a table into a partitioned table, consisting of many separate tables, each individually addressable.

Methods inherited from class io.deephaven.proto.backplane.grpc.PartitionedTableServiceGrpc.PartitionedTableServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Details

PartitionedTableServiceGrpcImpl

@Inject
public PartitionedTableServiceGrpcImpl(TicketRouter ticketRouter,
 SessionService sessionService,
 AuthorizationProvider authorizationProvider,
 PartitionedTableServiceContextualAuthWiring authWiring)

Method Details

partitionBy

public void partitionBy(@NotNull
 @NotNull PartitionByRequest request,
 @NotNull
 @NotNull io.grpc.stub.StreamObserver<PartitionByResponse> responseObserver)

Description copied from interface: PartitionedTableServiceGrpc.AsyncService

 Transforms a table into a partitioned table, consisting of many separate tables, each individually
 addressable. The result will be a FetchObjectResponse populated with a PartitionedTable.
 

merge

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

Description copied from interface: PartitionedTableServiceGrpc.AsyncService

 Given a partitioned table, returns a table with the contents of all of the constituent tables.
 

getTable

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

Description copied from interface: PartitionedTableServiceGrpc.AsyncService

 Given a partitioned table and a row described by another table's contents, returns a table
 that matched that row, if any. If none is present, NOT_FOUND will be sent in response. If
 more than one is present, FAILED_PRECONDITION will be sent in response.
 If the provided key table has any number of rows other than one, INVALID_ARGUMENT will be
 sent in response.
 The simplest way to generally use this is to subscribe to the key columns of the underlying
 table of a given PartitionedTable, then use /FlightService/DoPut to create a table with the
 desired keys, and pass that ticket to this service. After that request is sent (note that it
 is not required to wait for it to complete), that new table ticket can be used to make this
 GetTable request.