Package com.google.cloud.bigtable.data.v2.stub.readrows

Implementation details for EnhancedBigtableStub.readRowsCallable().

See: Description

Class Summary

Class	Description
FilterMarkerRowsCallable<RowT>	Remove the special marker rows generated by RowMergingCallable.
ReadRowsResumptionStrategy<RowT>	An implementation of a StreamResumptionStrategy for merged rows.
ReadRowsRetryCompletedCallable<RowT>	This callable addresses edge case of a ReadRows stream receiving all of the rows, but receiving a retryable error status instead of an OK.
ReadRowsUserCallable<RowT>	Simple wrapper for ReadRows to wrap the request protobufs.
RowMerger<RowT>	An implementation of a Reframer that feeds the row merging StateMachine.
RowMergingCallable<RowT>	A ServerStreamingCallable that will merge ReadRowsResponse.CellChunks into logical rows.

Package com.google.cloud.bigtable.data.v2.stub.readrows Description

Implementation details for EnhancedBigtableStub.readRowsCallable().

The ReadRows protocol is optimized for transmission and is not designed to be consumed directly. This package implements significant customizations on top of the raw GAPIC generated stub to handle row merging and retries.

• ReadRowsUserCallable: Creates protobuf ReadRowsRequests from user facing wrappers.
• RowMergingCallable (+ helpers): Implements a state machine that merges chunks into logical rows. The logical row representation is configurable via a RowAdapter. Please note that this will also emit special marker rows that help with retries in the next stage, but need to be filtered out.
• RowMerger (+ helpers): Implements resuming retries for gax's Callables#retrying middleware.
• FilterMarkerRowsCallable: Filters out marker rows that are used for efficient retry resumes. The marker is an internal implementation detail to communicate state to the RowMerger and should not be exposed to the caller.

This package is considered an internal implementation detail and is not meant to be used by applications directly.