NoOpWatermarkCache (google-cloud-platform 2.65.0 API)

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 Description

NoOpWatermarkCache(PartitionMetadataDao dao)

Method Summary

All Methods Instance Methods Concrete Methods
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 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.