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

Class NewPartition

java.lang.Object

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

All Implemented Interfaces:

Serializable

@Internal
public class NewPartition
extends Object
implements Serializable

Represent new partition as a result of splits and merges.

Parent partitions stop streaming and record their change stream continuation tokens. The tokens are collected to continue the stream from the new partition.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
NewPartition(Range.ByteStringRange partition, List<ChangeStreamContinuationToken> changeStreamContinuationTokens, Instant lowWatermark)
NewPartition(Range.ByteStringRange partition, List<ChangeStreamContinuationToken> changeStreamContinuationTokens, Instant lowWatermark, Instant lastUpdated)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
List<ChangeStreamContinuationToken>	getChangeStreamContinuationTokens()
Instant	getLastUpdated()
Instant	getLowWatermark()
List<Range.ByteStringRange>	getParentPartitions()
Range.ByteStringRange	getPartition()
NewPartition	getSingleTokenNewPartition(Range.ByteStringRange parentPartition)	Return a new NewPartition that only contains one token that matches the parentPartition.
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

NewPartition

public NewPartition(Range.ByteStringRange partition,
 List<ChangeStreamContinuationToken> changeStreamContinuationTokens,
 Instant lowWatermark,
 Instant lastUpdated)

NewPartition

public NewPartition(Range.ByteStringRange partition,
 List<ChangeStreamContinuationToken> changeStreamContinuationTokens,
 Instant lowWatermark)

Method Details

getPartition

public Range.ByteStringRange getPartition()

getChangeStreamContinuationTokens

public List<ChangeStreamContinuationToken> getChangeStreamContinuationTokens()

getLowWatermark

public Instant getLowWatermark()

getParentPartitions

public List<Range.ByteStringRange> getParentPartitions()

getLastUpdated

public Instant getLastUpdated()

getSingleTokenNewPartition

@Nullable
public NewPartition getSingleTokenNewPartition(Range.ByteStringRange parentPartition)

Return a new NewPartition that only contains one token that matches the parentPartition. If the parentPartition does not exist, return null.

Parameters:

parentPartition - to parent partition to find within the tokens.

Returns:

a NewPartition with one token with parentPartition. null otherwise.

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