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 java.lang.Object
implements WatermarkCache

Synchronously compute the earliest partition watermark, by delegating the call to PartitionMetadataDao.getUnfinishedMinWatermark().

Constructor Summary

Constructors

Constructor and Description
NoOpWatermarkCache(PartitionMetadataDao dao)

Method Summary

Modifier and Type	Method and 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 Detail

NoOpWatermarkCache

public NoOpWatermarkCache(PartitionMetadataDao dao)

Method Detail

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.