@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,
Instant parentLowWatermark,
java.util.List<NewPartition> parentPartitions) |
PartitionRecord(com.google.cloud.bigtable.data.v2.models.Range.ByteStringRange partition,
Instant startTime,
java.lang.String uuid,
Instant parentLowWatermark,
java.util.List<NewPartition> parentPartitions,
Instant endTime) |
PartitionRecord(com.google.cloud.bigtable.data.v2.models.Range.ByteStringRange partition,
java.util.List<com.google.cloud.bigtable.data.v2.models.ChangeStreamContinuationToken> changeStreamContinuationTokens,
Instant parentLowWatermark,
java.util.List<NewPartition> parentPartitions) |
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,
java.util.List<NewPartition> parentPartitions,
Instant endTime) |
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 |
getEndTime() |
Instant |
getParentLowWatermark() |
java.util.List<NewPartition> |
getParentPartitions() |
com.google.cloud.bigtable.data.v2.models.Range.ByteStringRange |
getPartition() |
Instant |
getStartTime() |
java.lang.String |
getUuid() |
int |
hashCode() |
void |
setEndTime(Instant endTime) |
void |
setUuid(java.lang.String uuid) |
java.lang.String |
toString() |
public PartitionRecord(com.google.cloud.bigtable.data.v2.models.Range.ByteStringRange partition, java.util.List<com.google.cloud.bigtable.data.v2.models.ChangeStreamContinuationToken> changeStreamContinuationTokens, Instant parentLowWatermark, java.util.List<NewPartition> parentPartitions)
public PartitionRecord(com.google.cloud.bigtable.data.v2.models.Range.ByteStringRange partition, Instant startTime, Instant parentLowWatermark, java.util.List<NewPartition> parentPartitions)
public PartitionRecord(com.google.cloud.bigtable.data.v2.models.Range.ByteStringRange partition, Instant startTime, java.lang.String uuid, Instant parentLowWatermark, java.util.List<NewPartition> parentPartitions, @Nullable Instant endTime)
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, java.util.List<NewPartition> parentPartitions, @Nullable Instant endTime)
public java.lang.String getUuid()
public Instant getParentLowWatermark()
public com.google.cloud.bigtable.data.v2.models.Range.ByteStringRange getPartition()
@Nullable public java.util.List<com.google.cloud.bigtable.data.v2.models.ChangeStreamContinuationToken> getChangeStreamContinuationTokens()
public java.util.List<NewPartition> getParentPartitions()
public void setUuid(java.lang.String uuid)
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