@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,
com.google.cloud.Timestamp startTime,
java.lang.String uuid,
com.google.cloud.Timestamp parentLowWatermark,
com.google.cloud.Timestamp endTime) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(java.lang.Object o) |
com.google.cloud.Timestamp |
getEndTime() |
com.google.cloud.Timestamp |
getParentLowWatermark() |
com.google.cloud.bigtable.data.v2.models.Range.ByteStringRange |
getPartition() |
com.google.cloud.Timestamp |
getStartTime() |
java.lang.String |
getUuid() |
int |
hashCode() |
void |
setEndTime(com.google.cloud.Timestamp endTime) |
void |
setParentLowWatermark(com.google.cloud.Timestamp parentLowWatermark) |
void |
setPartition(com.google.cloud.bigtable.data.v2.models.Range.ByteStringRange partition) |
void |
setStartTime(com.google.cloud.Timestamp startTime) |
void |
setUuid(java.lang.String uuid) |
java.lang.String |
toString() |
public PartitionRecord(com.google.cloud.bigtable.data.v2.models.Range.ByteStringRange partition, com.google.cloud.Timestamp startTime, java.lang.String uuid, com.google.cloud.Timestamp parentLowWatermark, @Nullable com.google.cloud.Timestamp endTime)
@Nullable public com.google.cloud.Timestamp getStartTime()
public void setStartTime(@Nullable com.google.cloud.Timestamp startTime)
@Nullable public com.google.cloud.Timestamp getEndTime()
public void setEndTime(@Nullable com.google.cloud.Timestamp endTime)
public java.lang.String getUuid()
public void setUuid(java.lang.String uuid)
public com.google.cloud.Timestamp getParentLowWatermark()
public void setParentLowWatermark(com.google.cloud.Timestamp 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)
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