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