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
.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
Methods in com.google.cloud.bigtable.data.v2.models that return ReadChangeStreamQuery Modifier and Type Method Description protected ReadChangeStreamQuery
ReadChangeStreamQuery. clone()
ReadChangeStreamQuery
ReadChangeStreamQuery. continuationTokens(List<ChangeStreamContinuationToken> changeStreamContinuationTokens)
Sets the stream continuation tokens to read the change stream.static ReadChangeStreamQuery
ReadChangeStreamQuery. create(String tableId)
Constructs a new ReadChangeStreamQuery object for the specified table id.ReadChangeStreamQuery
ReadChangeStreamQuery. endTime(org.threeten.bp.Instant value)
Sets the endTime to read the change stream.static ReadChangeStreamQuery
ReadChangeStreamQuery. fromProto(ReadChangeStreamRequest request)
Wraps the protobufReadChangeStreamRequest
.ReadChangeStreamQuery
ReadChangeStreamQuery. heartbeatDuration(org.threeten.bp.Duration duration)
Sets the heartbeat duration for the change stream.ReadChangeStreamQuery
ReadChangeStreamQuery. startTime(org.threeten.bp.Instant value)
Sets the startTime to read the change stream.ReadChangeStreamQuery
ReadChangeStreamQuery. streamPartition(RowRange rowRange)
Adds a partition.ReadChangeStreamQuery
ReadChangeStreamQuery. streamPartition(Range.ByteStringRange range)
Adds a partition.ReadChangeStreamQuery
ReadChangeStreamQuery. streamPartition(com.google.protobuf.ByteString start, com.google.protobuf.ByteString end)
Adds a partition.ReadChangeStreamQuery
ReadChangeStreamQuery. 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 void
ReadChangeStreamUserCallable. call(ReadChangeStreamQuery request, com.google.api.gax.rpc.ResponseObserver<ChangeStreamRecordT> responseObserver, com.google.api.gax.rpc.ApiCallContext context)
-