Package com.google.cloud.bigtable.grpc.scanner
-
Interface Summary Interface Description BigtableResultScannerFactory<ResponseT> A factory for creating ResultScanners that can be used to scan over Rows for a given ReadRowsRequest.ResultScanner<T> A scanner of Bigtable rows.ScanHandler An interface that handles timeout exception situations and request cancellations in scan situations. -
Class Summary Class Description FlatRow This class stores represents a single row.FlatRow.Builder FlatRow.Cell FlatRow.Cell.Builder FlatRowAdapter Adapter forRowAdapter
that usesFlatRow
's to represent logical rows.FlatRowConverter This class converts between instances ofFlatRow
andRow
.OutstandingRequestCountListener<ResponseT> AClientCall.Listener
that wraps aStreamObserver
and decrements outstandingRequestCount when a message is received.ResponseQueueReader Manages a queue ofResultQueueEntry
s ofFlatRow
.ResumingStreamingResultScanner A ResultScanner that attempts to resume the readRows call when it encounters gRPC INTERNAL errors.RetryingReadRowsOperation An extension ofAbstractRetryingOperation
that manages retries for the readRows streaming RPC.RowMerger Builds a completeFlatRow
fromReadRowsResponse
objects.RowResultScanner<T> AResultScanner
that wraps GCJServerStream
.StreamObserverAdapter<T> Adapts aStreamObserver
to aClientCall.Listener
. -
Exception Summary Exception Description BigtableRetriesExhaustedException An Exception that is thrown when an operation fails, even in the face of retries.ScanTimeoutException An IOException that presents timeout when reading response.