Uses of Class
com.google.cloud.bigtable.data.v2.models.ReadChangeStreamQuery
-
Packages that use ReadChangeStreamQuery Package Description com.google.cloud.bigtable.data.v2 A client for the Cloud Bigtable data API.com.google.cloud.bigtable.data.v2.models com.google.cloud.bigtable.data.v2.stub com.google.cloud.bigtable.data.v2.stub.changestream -
-
Uses of ReadChangeStreamQuery in com.google.cloud.bigtable.data.v2
Methods in com.google.cloud.bigtable.data.v2 that return types with arguments of type ReadChangeStreamQuery Modifier and Type Method Description com.google.api.gax.rpc.ServerStreamingCallable<ReadChangeStreamQuery,ChangeStreamRecord>BigtableDataClient. readChangeStreamCallable()Streams back the results of the query.Methods in com.google.cloud.bigtable.data.v2 with parameters of type ReadChangeStreamQuery Modifier and Type Method Description com.google.api.gax.rpc.ServerStream<ChangeStreamRecord>BigtableDataClient. readChangeStream(ReadChangeStreamQuery query)Convenience method for synchronously streaming the results of aReadChangeStreamQuery.voidBigtableDataClient. readChangeStreamAsync(ReadChangeStreamQuery query, com.google.api.gax.rpc.ResponseObserver<ChangeStreamRecord> observer)Convenience method for asynchronously streaming the results of aReadChangeStreamQuery. -
Uses of ReadChangeStreamQuery in com.google.cloud.bigtable.data.v2.models
Methods in com.google.cloud.bigtable.data.v2.models that return ReadChangeStreamQuery Modifier and Type Method Description protected ReadChangeStreamQueryReadChangeStreamQuery. clone()ReadChangeStreamQueryReadChangeStreamQuery. continuationTokens(List<ChangeStreamContinuationToken> changeStreamContinuationTokens)Sets the stream continuation tokens to read the change stream.static ReadChangeStreamQueryReadChangeStreamQuery. create(String tableId)Constructs a new ReadChangeStreamQuery object for the specified table id.ReadChangeStreamQueryReadChangeStreamQuery. endTime(org.threeten.bp.Instant value)Sets the endTime to read the change stream.static ReadChangeStreamQueryReadChangeStreamQuery. fromProto(ReadChangeStreamRequest request)Wraps the protobufReadChangeStreamRequest.ReadChangeStreamQueryReadChangeStreamQuery. heartbeatDuration(org.threeten.bp.Duration duration)Sets the heartbeat duration for the change stream.ReadChangeStreamQueryReadChangeStreamQuery. startTime(org.threeten.bp.Instant value)Sets the startTime to read the change stream.ReadChangeStreamQueryReadChangeStreamQuery. streamPartition(RowRange rowRange)Adds a partition.ReadChangeStreamQueryReadChangeStreamQuery. streamPartition(Range.ByteStringRange range)Adds a partition.ReadChangeStreamQueryReadChangeStreamQuery. streamPartition(com.google.protobuf.ByteString start, com.google.protobuf.ByteString end)Adds a partition.ReadChangeStreamQueryReadChangeStreamQuery. streamPartition(String start, String end)Adds a partition. -
Uses of ReadChangeStreamQuery in com.google.cloud.bigtable.data.v2.stub
Methods in com.google.cloud.bigtable.data.v2.stub that return types with arguments of type ReadChangeStreamQuery Modifier and Type Method Description com.google.api.gax.rpc.ServerStreamingCallSettings.Builder<ReadChangeStreamQuery,ChangeStreamRecord>EnhancedBigtableStubSettings.Builder. readChangeStreamSettings()Returns the builder for the settings used for calls to ReadChangeStream.com.google.api.gax.rpc.ServerStreamingCallSettings<ReadChangeStreamQuery,ChangeStreamRecord>EnhancedBigtableStubSettings. readChangeStreamSettings() -
Uses of ReadChangeStreamQuery in com.google.cloud.bigtable.data.v2.stub.changestream
Methods in com.google.cloud.bigtable.data.v2.stub.changestream with parameters of type ReadChangeStreamQuery Modifier and Type Method Description voidReadChangeStreamUserCallable. call(ReadChangeStreamQuery request, com.google.api.gax.rpc.ResponseObserver<ChangeStreamRecordT> responseObserver, com.google.api.gax.rpc.ApiCallContext context)
-