org.apache.paimon.flink.lookup

Class SecondaryIndexLookupTable

java.lang.Object

org.apache.paimon.flink.lookup.FullCacheLookupTable

org.apache.paimon.flink.lookup.PrimaryKeyLookupTable

org.apache.paimon.flink.lookup.SecondaryIndexLookupTable

All Implemented Interfaces:

Closeable, AutoCloseable, LookupTable

public class SecondaryIndexLookupTable
extends PrimaryKeyLookupTable

A LookupTable for primary key table which provides lookup by secondary key.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.paimon.flink.lookup.FullCacheLookupTable

FullCacheLookupTable.Context, FullCacheLookupTable.TableBulkLoader

Field Summary

Fields inherited from class org.apache.paimon.flink.lookup.PrimaryKeyLookupTable

lruCacheSize, primaryKeyRow, tableState

Fields inherited from class org.apache.paimon.flink.lookup.FullCacheLookupTable

appendUdsFieldNumber, context, lock, projectedType, refreshAsync, stateFactory, userDefinedSeqComparator

Constructor Summary

Constructors

Constructor and Description
SecondaryIndexLookupTable(FullCacheLookupTable.Context context, long lruCacheSize)

Method Summary

Modifier and Type	Method and Description
void	bulkLoadWritePlus(byte[] key, byte[] value)
List<InternalRow>	innerGet(InternalRow key)
void	open()
protected void	refreshRow(InternalRow row, Predicate predicate)

Methods inherited from class org.apache.paimon.flink.lookup.PrimaryKeyLookupTable

createBulkLoader, createTableState, toKeyBytes, toValueBytes

Methods inherited from class org.apache.paimon.flink.lookup.FullCacheLookupTable

bootstrap, close, get, openStateFactory, projectedPredicate, refresh, refresh, specificPartitionFilter, specifyCacheRowFilter

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SecondaryIndexLookupTable

public SecondaryIndexLookupTable(FullCacheLookupTable.Context context,
                                 long lruCacheSize)

Method Detail

open

public void open()
          throws Exception

Specified by:

open in interface LookupTable

Overrides:

open in class PrimaryKeyLookupTable

Throws:

Exception

innerGet

public List<InternalRow> innerGet(InternalRow key)
                           throws IOException

Overrides:

innerGet in class PrimaryKeyLookupTable

Throws:

IOException

refreshRow

protected void refreshRow(InternalRow row,
                          Predicate predicate)
                   throws IOException

Overrides:

refreshRow in class PrimaryKeyLookupTable

Throws:

IOException

bulkLoadWritePlus

public void bulkLoadWritePlus(byte[] key,
                              byte[] value)
                       throws IOException

Overrides:

bulkLoadWritePlus in class PrimaryKeyLookupTable

Throws:

IOException