Interface FullCachingLookupProvider
-
- All Superinterfaces:
LookupFunctionProvider
,LookupTableSource.LookupRuntimeProvider
@PublicEvolving public interface FullCachingLookupProvider extends LookupFunctionProvider
ALookupFunctionProvider
that never lookup in external system on cache miss and provides a cache for holding all entries in the external system. The cache will be fully reloaded from the external system by theScanTableSource.ScanRuntimeProvider
and reload operations will be triggered by theCacheReloadTrigger
.
-
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Modifier and Type Method Description CacheReloadTrigger
getCacheReloadTrigger()
Get aCacheReloadTrigger
for triggering the reload operation.ScanTableSource.ScanRuntimeProvider
getScanRuntimeProvider()
Get aScanTableSource.ScanRuntimeProvider
for scanning all entries from the external lookup table and load into the cache.static FullCachingLookupProvider
of(ScanTableSource.ScanRuntimeProvider scanRuntimeProvider, CacheReloadTrigger cacheReloadTrigger)
Build aFullCachingLookupProvider
from the specifiedScanTableSource.ScanRuntimeProvider
andCacheReloadTrigger
.-
Methods inherited from interface org.apache.flink.table.connector.source.lookup.LookupFunctionProvider
createLookupFunction
-
-
-
-
Method Detail
-
of
static FullCachingLookupProvider of(ScanTableSource.ScanRuntimeProvider scanRuntimeProvider, CacheReloadTrigger cacheReloadTrigger)
Build aFullCachingLookupProvider
from the specifiedScanTableSource.ScanRuntimeProvider
andCacheReloadTrigger
.
-
getScanRuntimeProvider
ScanTableSource.ScanRuntimeProvider getScanRuntimeProvider()
Get aScanTableSource.ScanRuntimeProvider
for scanning all entries from the external lookup table and load into the cache.
-
getCacheReloadTrigger
CacheReloadTrigger getCacheReloadTrigger()
Get aCacheReloadTrigger
for triggering the reload operation.
-
-