Uses of Interface
org.apache.flink.table.connector.source.lookup.cache.trigger.CacheReloadTrigger
-
-
Uses of CacheReloadTrigger in org.apache.flink.table.connector.source.lookup
Methods in org.apache.flink.table.connector.source.lookup that return CacheReloadTrigger Modifier and Type Method Description CacheReloadTrigger
FullCachingLookupProvider. getCacheReloadTrigger()
Get aCacheReloadTrigger
for triggering the reload operation.Methods in org.apache.flink.table.connector.source.lookup with parameters of type CacheReloadTrigger Modifier and Type Method Description static FullCachingLookupProvider
FullCachingLookupProvider. of(ScanTableSource.ScanRuntimeProvider scanRuntimeProvider, CacheReloadTrigger cacheReloadTrigger)
Build aFullCachingLookupProvider
from the specifiedScanTableSource.ScanRuntimeProvider
andCacheReloadTrigger
. -
Uses of CacheReloadTrigger in org.apache.flink.table.connector.source.lookup.cache.trigger
Classes in org.apache.flink.table.connector.source.lookup.cache.trigger that implement CacheReloadTrigger Modifier and Type Class Description class
PeriodicCacheReloadTrigger
A trigger that reloads cache entries periodically with specified interval andPeriodicCacheReloadTrigger.ScheduleMode
.class
TimedCacheReloadTrigger
A trigger that reloads at a specific time and repeats for the given interval in days. -
Uses of CacheReloadTrigger in org.apache.flink.table.runtime.functions.table.lookup.fullcache
Constructors in org.apache.flink.table.runtime.functions.table.lookup.fullcache with parameters of type CacheReloadTrigger Constructor Description LookupFullCache(CacheLoader cacheLoader, CacheReloadTrigger reloadTrigger)
-