Send feedback
Class ReadChangeStreamQuery (2.29.1)
Stay organized with collections
Save and categorize content based on your preferences.
Version 2.29.1 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 tableIdString
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 requestcom.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 valueorg.threeten.bp.Instant
equals(Object o)
public boolean equals ( Object o )
Parameter Name Description oObject
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 durationorg.threeten.bp.Duration
startTime(Instant value)
public ReadChangeStreamQuery startTime ( Instant value )
Sets the startTime to read the change stream.
Parameter Name Description valueorg.threeten.bp.Instant
streamPartition(RowRange rowRange)
public ReadChangeStreamQuery streamPartition ( RowRange rowRange )
Parameter Name Description rowRangecom.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 startByteString The beginning of the range (inclusive). Can be null to represent negative
infinity.
endByteString 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 startString The beginning of the range (inclusive). Can be null to represent negative
infinity.
endString 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 requestContextcom.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-12-19 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-12-19 UTC."],[],[]]
