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