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

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