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

Class CacheLoader

java.lang.Object

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

All Implemented Interfaces:

Serializable, AutoCloseable

Direct Known Subclasses:

InputFormatCacheLoader

public abstract class CacheLoader
extends Object
implements AutoCloseable, Serializable

Abstract task that loads data in Full cache from source provided by ScanTableSource.ScanRuntimeProvider.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected ConcurrentHashMap<org.apache.flink.table.data.RowData,Collection<org.apache.flink.table.data.RowData>>	cache
protected boolean	isStopped
protected static long	TIMEOUT_AFTER_INTERRUPT_MS

Constructor Summary

Constructors

Constructor	Description
CacheLoader()

Method Summary

Modifier and Type	Method	Description
void	awaitFirstLoad()
void	close()
ConcurrentHashMap<org.apache.flink.table.data.RowData,Collection<org.apache.flink.table.data.RowData>>	getCache()
void	initializeMetrics(org.apache.flink.metrics.groups.CacheMetricGroup cacheMetricGroup)
void	open(org.apache.flink.configuration.Configuration parameters, ClassLoader userCodeClassLoader)
CompletableFuture<Void>	reloadAsync()
protected abstract boolean	updateCache()

Methods inherited from class java.lang.Object

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

Field Detail

TIMEOUT_AFTER_INTERRUPT_MS

protected static final long TIMEOUT_AFTER_INTERRUPT_MS

See Also:

Constant Field Values

cache

protected transient volatile ConcurrentHashMap<org.apache.flink.table.data.RowData,Collection<org.apache.flink.table.data.RowData>> cache

isStopped

protected volatile boolean isStopped

Constructor Detail

CacheLoader

public CacheLoader()

Method Detail

updateCache

protected abstract boolean updateCache()
                                throws Exception

Returns:

whether reload was successful and was not interrupted.

Throws:

Exception

open

public void open(org.apache.flink.configuration.Configuration parameters,
                 ClassLoader userCodeClassLoader)
          throws Exception

Throws:

Exception

initializeMetrics

public void initializeMetrics(org.apache.flink.metrics.groups.CacheMetricGroup cacheMetricGroup)

getCache

public ConcurrentHashMap<org.apache.flink.table.data.RowData,Collection<org.apache.flink.table.data.RowData>> getCache()

awaitFirstLoad

public void awaitFirstLoad()
                    throws InterruptedException

Throws:

InterruptedException

reloadAsync

public CompletableFuture<Void> reloadAsync()

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception