Class 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 of LookupCache which 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 Detail

      • RefCountedCache

        public RefCountedCache​(org.apache.flink.table.connector.source.lookup.cache.LookupCache cache)
    • Method Detail

      • retain

        public void retain()
        Specified by:
        retain in interface org.apache.flink.util.RefCounted
      • release

        public boolean release()
        Specified by:
        release in interface org.apache.flink.util.RefCounted
      • getCache

        public org.apache.flink.table.connector.source.lookup.cache.LookupCache getCache()