Package com.google.cloud.bigtable.data.v2.stub.changestream
-
Class Summary Class Description ChangeStreamRecordMerger<ChangeStreamRecordT> An implementation of aReframer
that feeds the change stream record mergingChangeStreamStateMachine
.ChangeStreamRecordMergingCallable<ChangeStreamRecordT> A ServerStreamingCallable that consumesReadChangeStreamResponse
s and produces change stream records.GenerateInitialChangeStreamPartitionsUserCallable Simple wrapper for GenerateInitialChangeStreamPartitions to wrap the request and response protobufs.ReadChangeStreamResumptionStrategy<ChangeStreamRecordT> An implementation of aStreamResumptionStrategy
for change stream records.ReadChangeStreamUserCallable<ChangeStreamRecordT> A ServerStreamingCallable that converts aReadChangeStreamQuery
to aReadChangeStreamRequest
.