Package io.deephaven.server.table.inputtables

Class InputTableServiceGrpcImpl

java.lang.Object

io.deephaven.proto.backplane.grpc.InputTableServiceGrpc.InputTableServiceImplBase

io.deephaven.server.table.inputtables.InputTableServiceGrpcImpl

All Implemented Interfaces:

InputTableServiceGrpc.AsyncService, io.grpc.BindableService

public class InputTableServiceGrpcImpl
extends InputTableServiceGrpc.InputTableServiceImplBase

Constructor Summary

Constructors

Constructor	Description
InputTableServiceGrpcImpl(InputTableServiceContextualAuthWiring authWiring, TicketRouter ticketRouter, SessionService sessionService)

Method Summary

Modifier and Type	Method	Description
void	addTableToInputTable(@NotNull AddTableRequest request, @NotNull io.grpc.stub.StreamObserver<AddTableResponse> responseObserver)	Adds the provided table to the specified input table.
void	deleteTableFromInputTable(@NotNull DeleteTableRequest request, @NotNull io.grpc.stub.StreamObserver<DeleteTableResponse> responseObserver)	Removes the provided table from the specified input tables.

Methods inherited from class io.deephaven.proto.backplane.grpc.InputTableServiceGrpc.InputTableServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Details

InputTableServiceGrpcImpl

@Inject
public InputTableServiceGrpcImpl(InputTableServiceContextualAuthWiring authWiring,
 TicketRouter ticketRouter,
 SessionService sessionService)

Method Details

addTableToInputTable

public void addTableToInputTable(@NotNull
 @NotNull AddTableRequest request,
 @NotNull
 @NotNull io.grpc.stub.StreamObserver<AddTableResponse> responseObserver)

Description copied from interface: InputTableServiceGrpc.AsyncService

 Adds the provided table to the specified input table. The new data to add must only have
 columns (name, types, and order) which match the given input table's columns.
 

deleteTableFromInputTable

public void deleteTableFromInputTable(@NotNull
 @NotNull DeleteTableRequest request,
 @NotNull
 @NotNull io.grpc.stub.StreamObserver<DeleteTableResponse> responseObserver)

Description copied from interface: InputTableServiceGrpc.AsyncService

 Removes the provided table from the specified input tables. The tables indicating which rows
 to remove are expected to only have columns that match the key columns of the input table.