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

Class GenerateInitialChangeStreamPartitionsUserCallable

java.lang.Object
com.google.api.gax.rpc.ServerStreamingCallable<String,Range.ByteStringRange>
com.google.cloud.bigtable.data.v2.stub.changestream.GenerateInitialChangeStreamPartitionsUserCallable
public class GenerateInitialChangeStreamPartitionsUserCallable extends com.google.api.gax.rpc.ServerStreamingCallable<String,Range.ByteStringRange>
Simple wrapper for GenerateInitialChangeStreamPartitions to wrap the request and response protobufs.

  • Constructor Summary

    Constructors
    Constructor
    Description
    GenerateInitialChangeStreamPartitionsUserCallable(com.google.api.gax.rpc.ServerStreamingCallable<com.google.bigtable.v2.GenerateInitialChangeStreamPartitionsRequest,com.google.bigtable.v2.GenerateInitialChangeStreamPartitionsResponse> inner, com.google.cloud.bigtable.data.v2.internal.RequestContext requestContext)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    call(String tableId, com.google.api.gax.rpc.ResponseObserver<Range.ByteStringRange> 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

    • GenerateInitialChangeStreamPartitionsUserCallable

      public GenerateInitialChangeStreamPartitionsUserCallable(com.google.api.gax.rpc.ServerStreamingCallable<com.google.bigtable.v2.GenerateInitialChangeStreamPartitionsRequest,com.google.bigtable.v2.GenerateInitialChangeStreamPartitionsResponse> inner, com.google.cloud.bigtable.data.v2.internal.RequestContext requestContext)

  • Method Details

    • call

      public void call(String tableId, com.google.api.gax.rpc.ResponseObserver<Range.ByteStringRange> responseObserver, com.google.api.gax.rpc.ApiCallContext context)
      Specified by:
      call in class com.google.api.gax.rpc.ServerStreamingCallable<String,Range.ByteStringRange>