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

Class PartitionRestrictionSplitter

java.lang.Object

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

public class PartitionRestrictionSplitter
extends java.lang.Object

The PartitionRestrictionSplitter class.

Constructor Summary

Constructors

Constructor and Description
PartitionRestrictionSplitter()

Method Summary

Modifier and Type	Method and Description
@Nullable SplitResult<PartitionRestriction>	trySplit(double fractionOfRemainder, @Nullable PartitionPosition lastClaimedPosition, PartitionRestriction restriction)

Methods inherited from class java.lang.Object

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

Constructor Detail

PartitionRestrictionSplitter

public PartitionRestrictionSplitter()

Method Detail

trySplit

public @Nullable SplitResult<PartitionRestriction> trySplit(double fractionOfRemainder,
                                                            @Nullable PartitionPosition lastClaimedPosition,
                                                            PartitionRestriction restriction)