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

Class ReadChangeStreamUserCallable<ChangeStreamRecordT>

java.lang.Object
com.google.api.gax.rpc.ServerStreamingCallable<ReadChangeStreamQuery,ChangeStreamRecordT>
com.google.cloud.bigtable.data.v2.stub.changestream.ReadChangeStreamUserCallable<ChangeStreamRecordT>
@InternalApi("Used in Changestream beam pipeline.") public class ReadChangeStreamUserCallable<ChangeStreamRecordT> extends com.google.api.gax.rpc.ServerStreamingCallable<ReadChangeStreamQuery,ChangeStreamRecordT>
A ServerStreamingCallable that converts a ReadChangeStreamQuery to a ReadChangeStreamRequest.

  • Constructor Summary

    Constructors
    Constructor
    Description
    ReadChangeStreamUserCallable(com.google.api.gax.rpc.ServerStreamingCallable<com.google.bigtable.v2.ReadChangeStreamRequest,ChangeStreamRecordT> inner, com.google.cloud.bigtable.data.v2.internal.RequestContext requestContext)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    call(ReadChangeStreamQuery 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 Details

    • ReadChangeStreamUserCallable

      public ReadChangeStreamUserCallable(com.google.api.gax.rpc.ServerStreamingCallable<com.google.bigtable.v2.ReadChangeStreamRequest,ChangeStreamRecordT> inner, com.google.cloud.bigtable.data.v2.internal.RequestContext requestContext)

  • Method Details