org.apache.flink.table.runtime.functions.table.lookup.fullcache

Class LookupFullCache

java.lang.Object

org.apache.flink.table.runtime.functions.table.lookup.fullcache.LookupFullCache

All Implemented Interfaces:

Serializable, AutoCloseable, LookupCache

@Internal
public class LookupFullCache
extends Object
implements LookupCache

Internal implementation of LookupCache for LookupOptions.LookupCacheType.FULL.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
LookupFullCache(CacheLoader cacheLoader, CacheReloadTrigger reloadTrigger)

Method Summary

Modifier and Type	Method and Description
void	close()
Collection<RowData>	getIfPresent(RowData key) Returns the value associated with key in this cache, or null if there is no cached value for key.
void	invalidate(RowData key) Discards any cached value for the specified key.
void	open(CacheMetricGroup metricGroup) Initialize the cache.
Collection<RowData>	put(RowData key, Collection<RowData> value) Associates the specified value rows with the specified key row in the cache.
void	setUserCodeClassLoader(ClassLoader userCodeClassLoader)
long	size() Returns the number of key-value mappings in the cache.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LookupFullCache

public LookupFullCache(CacheLoader cacheLoader,
                       CacheReloadTrigger reloadTrigger)

Method Detail

setUserCodeClassLoader

public void setUserCodeClassLoader(ClassLoader userCodeClassLoader)

open

public void open(CacheMetricGroup metricGroup)

Description copied from interface: LookupCache

Initialize the cache.

Specified by:

open in interface LookupCache

Parameters:

metricGroup - the metric group to register cache related metrics.

getIfPresent

public Collection<RowData> getIfPresent(RowData key)

Description copied from interface: LookupCache

Returns the value associated with key in this cache, or null if there is no cached value for key.

Specified by:

getIfPresent in interface LookupCache

put

public Collection<RowData> put(RowData key,
                               Collection<RowData> value)

Description copied from interface: LookupCache

Associates the specified value rows with the specified key row in the cache. If the cache previously contained value associated with the key, the old value is replaced by the specified value.

Specified by:

put in interface LookupCache

Parameters:

key - - key row with which the specified value is to be associated

value - – value rows to be associated with the specified key

Returns:

the previous value rows associated with key, or null if there was no mapping for key.

invalidate

public void invalidate(RowData key)

Description copied from interface: LookupCache

Discards any cached value for the specified key.

Specified by:

invalidate in interface LookupCache

size

public long size()

Description copied from interface: LookupCache

Returns the number of key-value mappings in the cache.

Specified by:

size in interface LookupCache

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception