Package com.google.cloud.bigtable.data.v2.stub.changestream
package com.google.cloud.bigtable.data.v2.stub.changestream
-
ClassDescriptionChangeStreamRecordMerger<ChangeStreamRecordT>An implementation of a
Reframer
that feeds the change stream record mergingChangeStreamStateMachine
.ChangeStreamRecordMergingCallable<ChangeStreamRecordT>A ServerStreamingCallable that consumesReadChangeStreamResponse
s and produces change stream records.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
.