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:

java.io.Serializable

public class CacheFactory
extends java.lang.Object
implements java.io.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CacheFactory(DaoFactory daoFactory, Duration watermarkRefreshRate)

Method Summary

Modifier and Type	Method and Description
WatermarkCache	getWatermarkCache()

Methods inherited from class java.lang.Object

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

Constructor Detail

CacheFactory

public CacheFactory(DaoFactory daoFactory,
                    Duration watermarkRefreshRate)

Method Detail

getWatermarkCache

public WatermarkCache getWatermarkCache()