Uses of Interface
com.google.cloud.bigtable.data.v2.models.ChangeStreamRecord
-
Packages that use ChangeStreamRecord 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 -
-
Uses of ChangeStreamRecord in com.google.cloud.bigtable.data.v2
Methods in com.google.cloud.bigtable.data.v2 that return types with arguments of type ChangeStreamRecord 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
.com.google.api.gax.rpc.ServerStreamingCallable<ReadChangeStreamQuery,ChangeStreamRecord>
BigtableDataClient. readChangeStreamCallable()
Streams back the results of the query.Method parameters in com.google.cloud.bigtable.data.v2 with type arguments of type ChangeStreamRecord Modifier and Type Method Description void
BigtableDataClient. readChangeStreamAsync(ReadChangeStreamQuery query, com.google.api.gax.rpc.ResponseObserver<ChangeStreamRecord> observer)
Convenience method for asynchronously streaming the results of aReadChangeStreamQuery
. -
Uses of ChangeStreamRecord in com.google.cloud.bigtable.data.v2.models
Classes in com.google.cloud.bigtable.data.v2.models that implement ChangeStreamRecord Modifier and Type Class Description class
ChangeStreamMutation
A ChangeStreamMutation represents a list of mods(represented by List<Entry
>) targeted at a single row, which is concatenated byChangeStreamRecordMerger
.class
CloseStream
A simple wrapper forReadChangeStreamResponse.CloseStream
.class
Heartbeat
A simple wrapper forReadChangeStreamResponse.Heartbeat
.Methods in com.google.cloud.bigtable.data.v2.models that return types with arguments of type ChangeStreamRecord Modifier and Type Method Description ChangeStreamRecordAdapter.ChangeStreamRecordBuilder<ChangeStreamRecord>
DefaultChangeStreamRecordAdapter. createChangeStreamRecordBuilder()
Creates a new instance of aChangeStreamRecordAdapter.ChangeStreamRecordBuilder
.Methods in com.google.cloud.bigtable.data.v2.models with parameters of type ChangeStreamRecord Modifier and Type Method Description String
DefaultChangeStreamRecordAdapter. getTokenFromChangeStreamMutation(ChangeStreamRecord record)
Get the token from the given ChangeStreamMutation record.String
DefaultChangeStreamRecordAdapter. getTokenFromHeartbeat(ChangeStreamRecord record)
Get the token from the given Heartbeat record.boolean
DefaultChangeStreamRecordAdapter. isChangeStreamMutation(ChangeStreamRecord record)
Checks if the given change stream record is a ChangeStreamMutation.boolean
DefaultChangeStreamRecordAdapter. isHeartbeat(ChangeStreamRecord record)
Checks if the given change stream record is a Heartbeat. -
Uses of ChangeStreamRecord in com.google.cloud.bigtable.data.v2.stub
Methods in com.google.cloud.bigtable.data.v2.stub that return types with arguments of type ChangeStreamRecord 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()
-