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

Interface WatermarkCache

All Known Implementing Classes:

AsyncWatermarkCache, NoOpWatermarkCache

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface WatermarkCache

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.

Method Detail

getUnfinishedMinWatermark

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

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

Returns:

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