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

Class PartitionRestriction

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable

public class PartitionRestriction
extends java.lang.Object
implements java.io.Serializable

Represents the restriction for PartitionRestrictionTracker.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
PartitionRestriction(com.google.cloud.Timestamp startTimestamp, com.google.cloud.Timestamp endTimestamp, PartitionMode mode, @Nullable PartitionMode stoppedMode)

Method Summary

Modifier and Type	Method and Description
static PartitionRestriction	done(com.google.cloud.Timestamp startTimestamp, com.google.cloud.Timestamp endTimestamp)
boolean	equals(@Nullable java.lang.Object o)
com.google.cloud.Timestamp	getEndTimestamp()
PartitionRestrictionMetadata	getMetadata()
PartitionMode	getMode()
com.google.cloud.Timestamp	getStartTimestamp()
@Nullable PartitionMode	getStoppedMode()
int	hashCode()
static PartitionRestriction	queryChangeStream(com.google.cloud.Timestamp startTimestamp, com.google.cloud.Timestamp endTimestamp)
static PartitionRestriction	stop(PartitionRestriction restriction)
java.lang.String	toString()
static PartitionRestriction	updateState(com.google.cloud.Timestamp startTimestamp, com.google.cloud.Timestamp endTimestamp)
static PartitionRestriction	waitForChildPartitions(com.google.cloud.Timestamp startTimestamp, com.google.cloud.Timestamp endTimestamp)
PartitionRestriction	withMetadata(PartitionRestrictionMetadata metadata)

Methods inherited from class java.lang.Object

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

Constructor Detail

PartitionRestriction

public PartitionRestriction(com.google.cloud.Timestamp startTimestamp,
                            com.google.cloud.Timestamp endTimestamp,
                            PartitionMode mode,
                            @Nullable PartitionMode stoppedMode)

Method Detail

updateState

public static PartitionRestriction updateState(com.google.cloud.Timestamp startTimestamp,
                                               com.google.cloud.Timestamp endTimestamp)

queryChangeStream

public static PartitionRestriction queryChangeStream(com.google.cloud.Timestamp startTimestamp,
                                                     com.google.cloud.Timestamp endTimestamp)

waitForChildPartitions

public static PartitionRestriction waitForChildPartitions(com.google.cloud.Timestamp startTimestamp,
                                                          com.google.cloud.Timestamp endTimestamp)

done

public static PartitionRestriction done(com.google.cloud.Timestamp startTimestamp,
                                        com.google.cloud.Timestamp endTimestamp)

stop

public static PartitionRestriction stop(PartitionRestriction restriction)

withMetadata

public PartitionRestriction withMetadata(PartitionRestrictionMetadata metadata)

getStartTimestamp

public com.google.cloud.Timestamp getStartTimestamp()

getEndTimestamp

public com.google.cloud.Timestamp getEndTimestamp()

getMode

public PartitionMode getMode()

getStoppedMode

public @Nullable PartitionMode getStoppedMode()

getMetadata

public PartitionRestrictionMetadata getMetadata()

equals

public boolean equals(@Nullable java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object