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

Class CacheFactory

java.lang.Object

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

All Implemented Interfaces:

Serializable

public class CacheFactory
extends Object
implements Serializable

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
CacheFactory(DaoFactory daoFactory, Duration watermarkRefreshRate)

Method Summary

Modifier and Type	Method	Description
WatermarkCache	getWatermarkCache()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CacheFactory

public CacheFactory(DaoFactory daoFactory,
 Duration watermarkRefreshRate)

Method Details

getWatermarkCache

public WatermarkCache getWatermarkCache()