Send feedback
Class ReadChangeStreamQuery (2.33.0)
Stay organized with collections
Save and categorize content based on your preferences.
Version 2.33.0 keyboard_arrow_down
public final class ReadChangeStreamQuery implements Serializable, Cloneable
A simple wrapper to construct a query for the ReadChangeStream RPC.
Inheritance
Object >
ReadChangeStreamQuery
Static Methods
create(String tableId)
public static ReadChangeStreamQuery create(String tableId)
Parameter Name Description tableId
String
fromProto(ReadChangeStreamRequest request)
public static ReadChangeStreamQuery fromProto(ReadChangeStreamRequest request)
Wraps the protobuf ReadChangeStreamRequest .
WARNING: Please note that the project id & instance id in the table name will be overwritten
by the configuration in the BigtableDataClient.
Parameter Name Description request
com.google.bigtable.v2.ReadChangeStreamRequest
Methods
clone()
protected ReadChangeStreamQuery clone()
Overrides
continuationTokens(List<ChangeStreamContinuationToken> changeStreamContinuationTokens)
public ReadChangeStreamQuery continuationTokens(List<ChangeStreamContinuationToken> changeStreamContinuationTokens)
Sets the stream continuation tokens to read the change stream.
endTime(Instant value)
public ReadChangeStreamQuery endTime(Instant value)
Sets the endTime to read the change stream.
Parameter Name Description value
org.threeten.bp.Instant
equals(Object o)
public boolean equals(Object o)
Parameter Name Description o
Object
Overrides
hashCode()
Returns Type Description int
Overrides
heartbeatDuration(Duration duration)
public ReadChangeStreamQuery heartbeatDuration(Duration duration)
Sets the heartbeat duration for the change stream.
Parameter Name Description duration
org.threeten.bp.Duration
startTime(Instant value)
public ReadChangeStreamQuery startTime(Instant value)
Sets the startTime to read the change stream.
Parameter Name Description value
org.threeten.bp.Instant
streamPartition(RowRange rowRange)
public ReadChangeStreamQuery streamPartition(RowRange rowRange)
Parameter Name Description rowRange
com.google.bigtable.v2.RowRange
Represents the partition in the form [startKey, endKey). startKey can be null
to represent negative infinity. endKey can be null to represent positive infinity.
streamPartition(Range.ByteStringRange range)
public ReadChangeStreamQuery streamPartition(Range.ByteStringRange range)
streamPartition(ByteString start, ByteString end)
public ReadChangeStreamQuery streamPartition(ByteString start, ByteString end)
Parameters Name Description start
ByteString
The beginning of the range (inclusive). Can be null to represent negative
infinity.
end
ByteString
The end of the range (exclusive). Can be null to represent positive infinity.
streamPartition(String start, String end)
public ReadChangeStreamQuery streamPartition(String start, String end)
Parameters Name Description start
String
The beginning of the range (inclusive). Can be null to represent negative
infinity.
end
String
The end of the range (exclusive). Can be null to represent positive infinity.
toProto(RequestContext requestContext)
public ReadChangeStreamRequest toProto(RequestContext requestContext)
Creates the request protobuf. This method is considered an internal implementation detail and
not meant to be used by applications.
Parameter Name Description requestContext
com.google.cloud.bigtable.data.v2.internal.RequestContext
Returns Type Description com.google.bigtable.v2.ReadChangeStreamRequest
toString()
Overrides
Send feedback
Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License , and code samples are licensed under the Apache 2.0 License . For details, see the Google Developers Site Policies . Java is a registered trademark of Oracle and/or its affiliates.
Last updated 2024-10-30 UTC.
Need to tell us more?
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Hard to understand","hardToUnderstand","thumb-down"],["Incorrect information or sample code","incorrectInformationOrSampleCode","thumb-down"],["Missing the information/samples I need","missingTheInformationSamplesINeed","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2024-10-30 UTC."],[],[]]