THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
/** * A {@link CachingLookupProvider} 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 the {@link ScanTableSource.ScanRuntimeProvider} and reload operations will be * triggered by the {@link CacheReloadTrigger}. */ @PublicEvolving public interface FullCachingLookupProvider extends LookupFunctionProvider { static FullCachingLookupProvider of( ScanTableSource.ScanRuntimeProvider scanRuntimeProvider, CacheReloadTrigger cacheReloadTrigger) { return new FullCachingLookupProvider() { @Override public ScanTableSource.ScanRuntimeProvider getScanRuntimeProvider() { return scanRuntimeProvider; } @Override public CacheReloadTrigger getCacheReloadTrigger() { return cacheReloadTrigger; } @Override public LookupFunction createLookupFunction() { return keyRow -> null; } }; } /** * Get a {@link ScanTableSource.ScanRuntimeProvider} for scanning all entries from the external * lookup table and load into the cache. */ ScanTableSource.ScanRuntimeProvider getScanRuntimeProvider(); /** Get a {@link CacheReloadTrigger} for triggering the reload operation. */ CacheReloadTrigger getCacheReloadTrigger(); } |
...