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

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

Caching strategy for watermark.

Related Packages

Package	Description
org.apache.beam.sdk.io.gcp.spanner.changestreams	Provides an API for reading change stream data from Google Cloud Spanner.

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 invalid reference PartitionMetadataDao#getUnfinishedMinWatermark() .
WatermarkCache