Package org.apache.beam.sdk.io.gcp.spanner.changestreams.cache

Class NoOpWatermarkCache

java.lang.Object

org.apache.beam.sdk.io.gcp.spanner.changestreams.cache.NoOpWatermarkCache

All Implemented Interfaces:

WatermarkCache

public class NoOpWatermarkCache
extends Object
implements WatermarkCache

Synchronously compute the earliest partition watermark, by delegating the call to

invalid reference

PartitionMetadataDao#getUnfinishedMinWatermark()

.

Constructor Summary

Constructors

Constructor	Description
NoOpWatermarkCache(PartitionMetadataDao dao)

Method Summary

Modifier and Type	Method	Description
com.google.cloud.Timestamp	getUnfinishedMinWatermark()	Fetches the earliest partition watermark from the partition metadata table that is not in a PartitionMetadata.State.FINISHED state.

Methods inherited from class java.lang.Object

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

Constructor Details

NoOpWatermarkCache

public NoOpWatermarkCache(PartitionMetadataDao dao)

Method Details

getUnfinishedMinWatermark

@Nullable
public com.google.cloud.Timestamp getUnfinishedMinWatermark()

Description copied from interface: WatermarkCache

Fetches the earliest partition watermark from the partition metadata table that is not in a PartitionMetadata.State.FINISHED state.

Specified by:

getUnfinishedMinWatermark in interface WatermarkCache

Returns:

the earliest partition watermark which is not in a PartitionMetadata.State.FINISHED state.