@Internal public class StreamProgress extends java.lang.Object implements java.io.Serializable
ReadChangeStreamPartitionProgressTracker
. This represents contains
information that allows a stream, along with the PartitionRecord
to resume from a
checkpoint.
It should contain either a continuation token which represents a position in the stream, or it can contain a close stream message which represents an end to the stream and the DoFn needs to stop.
Constructor and Description |
---|
StreamProgress() |
StreamProgress(@Nullable com.google.cloud.bigtable.data.v2.models.ChangeStreamContinuationToken token,
Instant estimatedLowWatermark,
java.math.BigDecimal throughputEstimate,
Instant lastRunTimestamp,
boolean isHeartbeat) |
StreamProgress(@Nullable com.google.cloud.bigtable.data.v2.models.CloseStream closeStream) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(@Nullable java.lang.Object o) |
@Nullable com.google.cloud.bigtable.data.v2.models.CloseStream |
getCloseStream() |
@Nullable com.google.cloud.bigtable.data.v2.models.ChangeStreamContinuationToken |
getCurrentToken() |
@Nullable Instant |
getEstimatedLowWatermark() |
@Nullable Instant |
getLastRunTimestamp() |
@Nullable java.math.BigDecimal |
getThroughputEstimate() |
int |
hashCode() |
boolean |
isEmpty() |
boolean |
isFailToLock() |
boolean |
isHeartbeat() |
void |
setFailToLock(boolean failToLock) |
java.lang.String |
toString() |
public StreamProgress()
public StreamProgress(@Nullable com.google.cloud.bigtable.data.v2.models.ChangeStreamContinuationToken token, Instant estimatedLowWatermark, java.math.BigDecimal throughputEstimate, Instant lastRunTimestamp, boolean isHeartbeat)
public StreamProgress(@Nullable com.google.cloud.bigtable.data.v2.models.CloseStream closeStream)
public @Nullable com.google.cloud.bigtable.data.v2.models.ChangeStreamContinuationToken getCurrentToken()
public @Nullable Instant getEstimatedLowWatermark()
public @Nullable java.math.BigDecimal getThroughputEstimate()
public @Nullable Instant getLastRunTimestamp()
public @Nullable com.google.cloud.bigtable.data.v2.models.CloseStream getCloseStream()
public boolean isFailToLock()
public void setFailToLock(boolean failToLock)
public boolean isHeartbeat()
public boolean isEmpty()
public boolean equals(@Nullable java.lang.Object o)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object
public java.lang.String toString()
toString
in class java.lang.Object