@Internal public class PartitionRecord extends java.lang.Object implements java.io.Serializable
DetectNewPartitionsDoFn
containing
information required to stream a partition.Constructor and Description |
---|
PartitionRecord(com.google.cloud.bigtable.data.v2.models.Range.ByteStringRange partition,
Instant startTime,
java.lang.String uuid,
Instant parentLowWatermark) |
PartitionRecord(com.google.cloud.bigtable.data.v2.models.Range.ByteStringRange partition,
java.util.List<com.google.cloud.bigtable.data.v2.models.ChangeStreamContinuationToken> changeStreamContinuationTokens,
java.lang.String uuid,
Instant parentLowWatermark) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(java.lang.Object o) |
java.util.List<com.google.cloud.bigtable.data.v2.models.ChangeStreamContinuationToken> |
getChangeStreamContinuationTokens() |
Instant |
getParentLowWatermark() |
com.google.cloud.bigtable.data.v2.models.Range.ByteStringRange |
getPartition() |
Instant |
getStartTime() |
java.lang.String |
getUuid() |
int |
hashCode() |
void |
setChangeStreamContinuationTokens(java.util.List<com.google.cloud.bigtable.data.v2.models.ChangeStreamContinuationToken> changeStreamContinuationTokens) |
void |
setParentLowWatermark(Instant parentLowWatermark) |
void |
setPartition(com.google.cloud.bigtable.data.v2.models.Range.ByteStringRange partition) |
void |
setStartTime(Instant startTime) |
void |
setUuid(java.lang.String uuid) |
java.lang.String |
toString() |
public PartitionRecord(com.google.cloud.bigtable.data.v2.models.Range.ByteStringRange partition, Instant startTime, java.lang.String uuid, Instant parentLowWatermark)
public PartitionRecord(com.google.cloud.bigtable.data.v2.models.Range.ByteStringRange partition, java.util.List<com.google.cloud.bigtable.data.v2.models.ChangeStreamContinuationToken> changeStreamContinuationTokens, java.lang.String uuid, Instant parentLowWatermark)
public java.lang.String getUuid()
public void setUuid(java.lang.String uuid)
public Instant getParentLowWatermark()
public void setParentLowWatermark(Instant parentLowWatermark)
public com.google.cloud.bigtable.data.v2.models.Range.ByteStringRange getPartition()
public void setPartition(com.google.cloud.bigtable.data.v2.models.Range.ByteStringRange partition)
@Nullable public java.util.List<com.google.cloud.bigtable.data.v2.models.ChangeStreamContinuationToken> getChangeStreamContinuationTokens()
public void setChangeStreamContinuationTokens(@Nullable java.util.List<com.google.cloud.bigtable.data.v2.models.ChangeStreamContinuationToken> changeStreamContinuationTokens)
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