Uses of Class
com.google.cloud.bigtable.data.v2.models.ReadChangeStreamQuery
Package
Description
A client for the Cloud Bigtable data API.
-
Uses of ReadChangeStreamQuery in com.google.cloud.bigtable.data.v2
Modifier and TypeMethodDescriptioncom.google.api.gax.rpc.ServerStreamingCallable<ReadChangeStreamQuery,
ChangeStreamRecord> BigtableDataClient.readChangeStreamCallable()
Streams back the results of the query.Modifier and TypeMethodDescriptioncom.google.api.gax.rpc.ServerStream<ChangeStreamRecord>
BigtableDataClient.readChangeStream
(ReadChangeStreamQuery query) Convenience method for synchronously streaming the results of aReadChangeStreamQuery
.void
BigtableDataClient.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
Modifier and TypeMethodDescriptionprotected ReadChangeStreamQuery
ReadChangeStreamQuery.clone()
ReadChangeStreamQuery.continuationTokens
(List<ChangeStreamContinuationToken> changeStreamContinuationTokens) Sets the stream continuation tokens to read the change stream.static ReadChangeStreamQuery
Constructs a new ReadChangeStreamQuery object for the specified table id.ReadChangeStreamQuery.endTime
(org.threeten.bp.Instant value) Sets the endTime to read the change stream.static ReadChangeStreamQuery
ReadChangeStreamQuery.fromProto
(com.google.bigtable.v2.ReadChangeStreamRequest request) Wraps the protobufReadChangeStreamRequest
.ReadChangeStreamQuery.heartbeatDuration
(org.threeten.bp.Duration duration) Sets the heartbeat duration for the change stream.ReadChangeStreamQuery.startTime
(org.threeten.bp.Instant value) Sets the startTime to read the change stream.ReadChangeStreamQuery.streamPartition
(com.google.bigtable.v2.RowRange rowRange) Adds a partition.ReadChangeStreamQuery.streamPartition
(Range.ByteStringRange range) Adds a partition.ReadChangeStreamQuery.streamPartition
(com.google.protobuf.ByteString start, com.google.protobuf.ByteString end) Adds a partition.ReadChangeStreamQuery.streamPartition
(String start, String end) Adds a partition. -
Uses of ReadChangeStreamQuery in com.google.cloud.bigtable.data.v2.stub
Modifier and TypeMethodDescriptioncom.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
Modifier and TypeMethodDescriptionvoid
ReadChangeStreamUserCallable.call
(ReadChangeStreamQuery request, com.google.api.gax.rpc.ResponseObserver<ChangeStreamRecordT> responseObserver, com.google.api.gax.rpc.ApiCallContext context)