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

Caching strategy for watermark.

See: Description

Interface Summary

Interface	Description
WatermarkCache

Class Summary

Class	Description
AsyncWatermarkCache	Asynchronously compute the earliest partition watermark and stores it in memory.
CacheFactory
NoOpWatermarkCache	Synchronously compute the earliest partition watermark, by delegating the call to PartitionMetadataDao.getUnfinishedMinWatermark().

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

Caching strategy for watermark.