Package org.apache.beam.sdk.io.gcp.bigtable.changestreams.model

Class PartitionRecord

java.lang.Object

org.apache.beam.sdk.io.gcp.bigtable.changestreams.model.PartitionRecord

All Implemented Interfaces:

Serializable

@Internal
public class PartitionRecord
extends Object
implements Serializable

Output result of DetectNewPartitionsDoFn containing information required to stream a partition.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
PartitionRecord(Range.ByteStringRange partition, List<ChangeStreamContinuationToken> changeStreamContinuationTokens, String uuid, Instant parentLowWatermark, List<NewPartition> parentPartitions, Instant endTime)
PartitionRecord(Range.ByteStringRange partition, List<ChangeStreamContinuationToken> changeStreamContinuationTokens, Instant parentLowWatermark, List<NewPartition> parentPartitions)
PartitionRecord(Range.ByteStringRange partition, Instant startTime, String uuid, Instant parentLowWatermark, List<NewPartition> parentPartitions, Instant endTime)
PartitionRecord(Range.ByteStringRange partition, Instant startTime, Instant parentLowWatermark, List<NewPartition> parentPartitions)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
List<ChangeStreamContinuationToken>	getChangeStreamContinuationTokens()
Instant	getEndTime()
Instant	getParentLowWatermark()
List<NewPartition>	getParentPartitions()
Range.ByteStringRange	getPartition()
Instant	getStartTime()
String	getUuid()
int	hashCode()
void	setEndTime(Instant endTime)
void	setUuid(String uuid)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

PartitionRecord

public PartitionRecord(Range.ByteStringRange partition,
 List<ChangeStreamContinuationToken> changeStreamContinuationTokens,
 Instant parentLowWatermark,
 List<NewPartition> parentPartitions)

PartitionRecord

public PartitionRecord(Range.ByteStringRange partition,
 Instant startTime,
 Instant parentLowWatermark,
 List<NewPartition> parentPartitions)

PartitionRecord

public PartitionRecord(Range.ByteStringRange partition,
 Instant startTime,
 String uuid,
 Instant parentLowWatermark,
 List<NewPartition> parentPartitions,
 @Nullable
 Instant endTime)

PartitionRecord

public PartitionRecord(Range.ByteStringRange partition,
 List<ChangeStreamContinuationToken> changeStreamContinuationTokens,
 String uuid,
 Instant parentLowWatermark,
 List<NewPartition> parentPartitions,
 @Nullable
 Instant endTime)

Method Details

getStartTime

@Nullable
public Instant getStartTime()

getUuid

public String getUuid()

getParentLowWatermark

public Instant getParentLowWatermark()

getPartition

public Range.ByteStringRange getPartition()

getChangeStreamContinuationTokens

@Nullable
public List<ChangeStreamContinuationToken> getChangeStreamContinuationTokens()

getEndTime

@Nullable
public Instant getEndTime()

getParentPartitions

public List<NewPartition> getParentPartitions()

setUuid

public void setUuid(String uuid)

setEndTime

public void setEndTime(@Nullable
 Instant endTime)

equals

public boolean equals(@Nullable
 Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object