public interface LookupTable
Modifier and Type | Method and Description |
---|---|
static LookupTable |
create(RocksDBStateFactory stateFactory,
org.apache.flink.table.types.logical.RowType rowType,
List<String> primaryKey,
List<String> joinKey,
java.util.function.Predicate<org.apache.flink.table.data.RowData> recordFilter,
long lruCacheSize) |
List<org.apache.flink.table.data.RowData> |
get(org.apache.flink.table.data.RowData key) |
void |
refresh(Iterator<org.apache.flink.table.data.RowData> incremental) |
List<org.apache.flink.table.data.RowData> get(org.apache.flink.table.data.RowData key) throws IOException
IOException
void refresh(Iterator<org.apache.flink.table.data.RowData> incremental) throws IOException
IOException
static LookupTable create(RocksDBStateFactory stateFactory, org.apache.flink.table.types.logical.RowType rowType, List<String> primaryKey, List<String> joinKey, java.util.function.Predicate<org.apache.flink.table.data.RowData> recordFilter, long lruCacheSize) throws IOException
IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.