public class SecondaryIndexLookupTable extends PrimaryKeyLookupTable
LookupTable
for primary key table which provides lookup by secondary key.primaryKey, primaryKeyMapping, recordFilter, tableState
Constructor and Description |
---|
SecondaryIndexLookupTable(RocksDBStateFactory stateFactory,
org.apache.flink.table.types.logical.RowType rowType,
List<String> primaryKey,
List<String> secKey,
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
public SecondaryIndexLookupTable(RocksDBStateFactory stateFactory, org.apache.flink.table.types.logical.RowType rowType, List<String> primaryKey, List<String> secKey, 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
get
in class PrimaryKeyLookupTable
IOException
public void refresh(Iterator<org.apache.flink.table.data.RowData> incremental) throws IOException
refresh
in interface LookupTable
refresh
in class PrimaryKeyLookupTable
IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.