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