Send feedback
Class ReadChangeStreamQuery (2.45.1)
Stay organized with collections
Save and categorize content based on your preferences.
Version latest 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)
Internal Only : This feature is not stable for application use.
Used in Changestream beam pipeline.
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()
Returns
Type
Description
String
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."],[],[]]