Package | Description |
---|---|
org.apache.flink.table.runtime.functions.table.lookup.fullcache.inputformat | |
org.apache.flink.table.runtime.keyselector |
Constructor and Description |
---|
InputFormatCacheLoader(InputFormat<RowData,?> initialInputFormat,
GenericRowDataKeySelector keySelector,
RowDataSerializer cacheEntriesSerializer) |
InputSplitCacheLoadTask(ConcurrentHashMap<RowData,Collection<RowData>> cache,
GenericRowDataKeySelector keySelector,
RowDataSerializer cacheEntriesSerializer,
InputFormat<RowData,InputSplit> inputFormat,
InputSplit inputSplit) |
Modifier and Type | Method and Description |
---|---|
GenericRowDataKeySelector |
GenericRowDataKeySelector.copy() |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.