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

Class ChangeStreamRecordMergingCallable<ChangeStreamRecordT>

java.lang.Object

com.google.api.gax.rpc.ServerStreamingCallable<ReadChangeStreamRequest,ChangeStreamRecordT>

com.google.cloud.bigtable.data.v2.stub.changestream.ChangeStreamRecordMergingCallable<ChangeStreamRecordT>

@InternalApi
public class ChangeStreamRecordMergingCallable<ChangeStreamRecordT>
extends com.google.api.gax.rpc.ServerStreamingCallable<ReadChangeStreamRequest,ChangeStreamRecordT>

A ServerStreamingCallable that consumes ReadChangeStreamResponses and produces change stream records.

This class delegates all the work to gax's ReframingResponseObserver and the logic to ChangeStreamRecordMerger.

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

Constructor Summary

Constructors

Constructor	Description
ChangeStreamRecordMergingCallable(com.google.api.gax.rpc.ServerStreamingCallable<ReadChangeStreamRequest,ReadChangeStreamResponse> inner, ChangeStreamRecordAdapter<ChangeStreamRecordT> changeStreamRecordAdapter)

Method Summary

Modifier and Type	Method	Description
void	call(ReadChangeStreamRequest request, com.google.api.gax.rpc.ResponseObserver<ChangeStreamRecordT> responseObserver, com.google.api.gax.rpc.ApiCallContext context)

Methods inherited from class com.google.api.gax.rpc.ServerStreamingCallable

all, blockingServerStreamingCall, blockingServerStreamingCall, call, call, call, first, serverStreamingCall, serverStreamingCall, withDefaultCallContext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ChangeStreamRecordMergingCallable

public ChangeStreamRecordMergingCallable(com.google.api.gax.rpc.ServerStreamingCallable<ReadChangeStreamRequest,ReadChangeStreamResponse> inner,
                                         ChangeStreamRecordAdapter<ChangeStreamRecordT> changeStreamRecordAdapter)

Method Detail

call

public void call(ReadChangeStreamRequest request,
                 com.google.api.gax.rpc.ResponseObserver<ChangeStreamRecordT> responseObserver,
                 com.google.api.gax.rpc.ApiCallContext context)

Specified by:

call in class com.google.api.gax.rpc.ServerStreamingCallable<ReadChangeStreamRequest,ChangeStreamRecordT>