Class LookupCacheManager.RefCountedCache
- java.lang.Object
-
- org.apache.flink.table.runtime.functions.table.lookup.LookupCacheManager.RefCountedCache
-
- All Implemented Interfaces:
org.apache.flink.util.RefCounted
- Enclosing class:
- LookupCacheManager
@NotThreadSafe @VisibleForTesting public static class LookupCacheManager.RefCountedCache extends Object implements org.apache.flink.util.RefCounted
A wrapper class ofLookupCachewhich also tracks the reference count of it.This class is exposed as public for testing purpose and not thread safe. Concurrent accesses should be guarded by synchronized methods provided by
LookupCacheManager.
-
-
Constructor Summary
Constructors Constructor Description RefCountedCache(org.apache.flink.table.connector.source.lookup.cache.LookupCache cache)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.flink.table.connector.source.lookup.cache.LookupCachegetCache()booleanrelease()voidretain()
-
-
-
Method Detail
-
retain
public void retain()
- Specified by:
retainin interfaceorg.apache.flink.util.RefCounted
-
release
public boolean release()
- Specified by:
releasein interfaceorg.apache.flink.util.RefCounted
-
getCache
public org.apache.flink.table.connector.source.lookup.cache.LookupCache getCache()
-
-