Package io.deephaven.proto.backplane.grpc

Class PartitionedTableServiceGrpc.PartitionedTableServiceFutureStub

java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractFutureStub<PartitionedTableServiceGrpc.PartitionedTableServiceFutureStub>
io.deephaven.proto.backplane.grpc.PartitionedTableServiceGrpc.PartitionedTableServiceFutureStub
Enclosing class:
PartitionedTableServiceGrpc
public static final class PartitionedTableServiceGrpc.PartitionedTableServiceFutureStub extends io.grpc.stub.AbstractFutureStub<PartitionedTableServiceGrpc.PartitionedTableServiceFutureStub>
A stub to allow clients to do ListenableFuture-style rpc calls to service PartitionedTableService. 
 This service provides tools to create and query partitioned tables.

  • 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
    protected PartitionedTableServiceGrpc.PartitionedTableServiceFutureStub
    build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
     
    com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>
    getTable(GetTableRequest request)
    Given a partitioned table and a row described by another table's contents, returns a table that matched that row, if any.
    com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse>
    merge(MergeRequest request)
    Given a partitioned table, returns a table with the contents of all of the constituent tables.
    com.google.common.util.concurrent.ListenableFuture<PartitionByResponse>
    partitionBy(PartitionByRequest request)
    Transforms a table into a partitioned table, consisting of many separate tables, each individually addressable.

    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 PartitionedTableServiceGrpc.PartitionedTableServiceFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
      Specified by:
      build in class io.grpc.stub.AbstractStub<PartitionedTableServiceGrpc.PartitionedTableServiceFutureStub>

    • partitionBy

      public com.google.common.util.concurrent.ListenableFuture<PartitionByResponse> partitionBy(PartitionByRequest request)
       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 com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> merge(MergeRequest request)
       Given a partitioned table, returns a table with the contents of all of the constituent tables.

    • getTable

      public com.google.common.util.concurrent.ListenableFuture<ExportedTableCreationResponse> getTable(GetTableRequest request)
       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.