public class InputFormatCacheLoader extends CacheLoader
CacheLoader
that used InputFormat
for loading data into the cache.cache, isStopped, TIMEOUT_AFTER_INTERRUPT_MS
Constructor and Description |
---|
InputFormatCacheLoader(InputFormat<RowData,?> initialInputFormat,
GenericRowDataKeySelector keySelector,
RowDataSerializer cacheEntriesSerializer) |
Modifier and Type | Method and Description |
---|---|
void |
open(Configuration parameters,
ClassLoader userCodeClassLoader) |
protected boolean |
updateCache() |
awaitFirstLoad, close, getCache, initializeMetrics, reloadAsync
public InputFormatCacheLoader(InputFormat<RowData,?> initialInputFormat, GenericRowDataKeySelector keySelector, RowDataSerializer cacheEntriesSerializer)
public void open(Configuration parameters, ClassLoader userCodeClassLoader) throws Exception
open
in class CacheLoader
Exception
protected boolean updateCache() throws Exception
updateCache
in class CacheLoader
Exception
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.