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 and Description
protected ConcurrentHashMap<RowData,Collection<RowData>>	cache
protected boolean	isStopped
protected static long	TIMEOUT_AFTER_INTERRUPT_MS

Constructor Summary

Constructors

Constructor and Description
CacheLoader()

Method Summary

Modifier and Type	Method and Description
void	awaitFirstLoad()
void	close()
ConcurrentHashMap<RowData,Collection<RowData>>	getCache()
void	initializeMetrics(CacheMetricGroup cacheMetricGroup)
void	open(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<RowData,Collection<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(Configuration parameters,
                 ClassLoader userCodeClassLoader)
          throws Exception

Throws:

Exception

initializeMetrics

public void initializeMetrics(CacheMetricGroup cacheMetricGroup)

getCache

public ConcurrentHashMap<RowData,Collection<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