org.apache.beam.sdk.io.gcp.spanner.changestreams.restriction

Class PartitionRestrictionProgressChecker

java.lang.Object

org.apache.beam.sdk.io.gcp.spanner.changestreams.restriction.PartitionRestrictionProgressChecker

public class PartitionRestrictionProgressChecker
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.function.Supplier<com.google.cloud.Timestamp>	timeSupplier

Constructor Summary

Constructors

Constructor and Description
PartitionRestrictionProgressChecker() Indicates how many mode transitions have been completed for the current mode.

Method Summary

Modifier and Type	Method and Description
RestrictionTracker.Progress	getProgress(PartitionRestriction restriction, @Nullable PartitionPosition lastClaimedPosition)
void	setTimeSupplier(java.util.function.Supplier<com.google.cloud.Timestamp> timeSupplier)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

timeSupplier

protected java.util.function.Supplier<com.google.cloud.Timestamp> timeSupplier

Constructor Detail

PartitionRestrictionProgressChecker

public PartitionRestrictionProgressChecker()

Indicates how many mode transitions have been completed for the current mode. The transitions are as follows: * (1) UPDATE_STATE, (2) QUERY_CHANGE_STREAM, (3) WAIT_FOR_CHILD_PARTITIONS, (4) DONE.

This is used to calculate the units of work left, meaning that 1 transition = 1 unit of work.

Method Detail

setTimeSupplier

public void setTimeSupplier(java.util.function.Supplier<com.google.cloud.Timestamp> timeSupplier)

getProgress

public RestrictionTracker.Progress getProgress(PartitionRestriction restriction,
                                               @Nullable PartitionPosition lastClaimedPosition)