@InternalApi public class EnhancedBigtableStub extends Object implements AutoCloseable
This class consists of a set of Callable chains that represent RPC methods. There is a chain
for each RPC method. Each chain starts with a transformation that takes a protobuf wrapper and
terminates in a Callable from GrpcBigtableStub
. This class is meant to be a semantically
complete facade for the Bigtable data API. However it is not meant to be consumed directly,
please use BigtableDataClient
.
This class is considered an internal implementation detail and not meant to be used by applications.
public static EnhancedBigtableStub create(EnhancedBigtableStubSettings settings) throws IOException
IOException
public <RowT> ServerStreamingCallable<Query,RowT> createReadRowsCallable(RowAdapter<RowT> rowAdapter)
Query
into a ReadRowsRequest
and
dispatch the RPC.
ReadRowsResponse.CellChunk
s in logical rows. The actual row
implementation can be configured in by the rowAdapter
parameter.
public <RowT> UnaryCallable<Query,RowT> createReadRowCallable(RowAdapter<RowT> rowAdapter)
Query
into a ReadRowsRequest
and
dispatch the RPC.
ReadRowsResponse.CellChunk
s in logical rows. The actual row
implementation can be configured in by the rowAdapter
parameter.
public ServerStreamingCallable<Query,Row> readRowsCallable()
public UnaryCallable<Query,Row> readRowCallable()
public UnaryCallable<String,List<KeyOffset>> sampleRowKeysCallable()
public UnaryCallable<RowMutation,Void> mutateRowCallable()
public UnaryCallable<BulkMutation,Void> bulkMutateRowsCallable()
createBulkMutateRowsCallable()
()} during stub
construction.public UnaryCallable<RowMutation,Void> bulkMutateRowsBatchingCallable()
createBulkMutateRowsBatchingCallable()
()}
during stub construction.public UnaryCallable<ConditionalRowMutation,Boolean> checkAndMutateRowCallable()
createCheckAndMutateRowCallable()
during stub
construction.public UnaryCallable<ReadModifyWriteRow,Row> readModifyWriteRowCallable()
createReadModifyWriteRowCallable()
()} during
stub construction.public void close() throws Exception
close
in interface AutoCloseable
Exception
Copyright © 2019 Google LLC. All rights reserved.