public class PrimaryKeyLookupTable extends Object implements LookupTable
LookupTable
for primary key table.Modifier and Type | Field and Description |
---|---|
protected KeyProjectedRowData |
primaryKey |
protected int[] |
primaryKeyMapping |
protected java.util.function.Predicate<org.apache.flink.table.data.RowData> |
recordFilter |
protected RocksDBValueState |
tableState |
Constructor and Description |
---|
PrimaryKeyLookupTable(RocksDBStateFactory stateFactory,
org.apache.flink.table.types.logical.RowType rowType,
List<String> primaryKey,
java.util.function.Predicate<org.apache.flink.table.data.RowData> recordFilter,
long lruCacheSize) |
Modifier and Type | Method and Description |
---|---|
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) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
create
protected final RocksDBValueState tableState
protected final java.util.function.Predicate<org.apache.flink.table.data.RowData> recordFilter
protected int[] primaryKeyMapping
protected final KeyProjectedRowData primaryKey
public PrimaryKeyLookupTable(RocksDBStateFactory stateFactory, org.apache.flink.table.types.logical.RowType rowType, List<String> primaryKey, java.util.function.Predicate<org.apache.flink.table.data.RowData> recordFilter, long lruCacheSize) throws IOException
IOException
public List<org.apache.flink.table.data.RowData> get(org.apache.flink.table.data.RowData key) throws IOException
get
in interface LookupTable
IOException
public void refresh(Iterator<org.apache.flink.table.data.RowData> incremental) throws IOException
refresh
in interface LookupTable
IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.