org.apache.paimon.flink.lookup

Class PrimaryKeyLookupTable

java.lang.Object

org.apache.paimon.flink.lookup.FullCacheLookupTable

org.apache.paimon.flink.lookup.PrimaryKeyLookupTable

All Implemented Interfaces:

Closeable, AutoCloseable, LookupTable

Direct Known Subclasses:

SecondaryIndexLookupTable

public class PrimaryKeyLookupTable
extends FullCacheLookupTable

A LookupTable for primary key table.

Nested Class Summary

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

FullCacheLookupTable.Context, FullCacheLookupTable.TableBulkLoader

Field Summary

Fields

Modifier and Type	Field and Description
protected long	lruCacheSize
protected KeyProjectedRow	primaryKeyRow
protected RocksDBValueState<InternalRow,InternalRow>	tableState

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

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

Constructor Summary

Constructors

Constructor and Description
PrimaryKeyLookupTable(FullCacheLookupTable.Context context, long lruCacheSize, List<String> joinKey)

Method Summary

Modifier and Type	Method and Description
void	bulkLoadWritePlus(byte[] key, byte[] value)
FullCacheLookupTable.TableBulkLoader	createBulkLoader()
protected void	createTableState()
List<InternalRow>	innerGet(InternalRow key)
void	open()
protected void	refreshRow(InternalRow row, Predicate predicate)
byte[]	toKeyBytes(InternalRow row)
byte[]	toValueBytes(InternalRow row)

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

Field Detail

lruCacheSize

protected final long lruCacheSize

primaryKeyRow

protected final KeyProjectedRow primaryKeyRow

tableState

protected RocksDBValueState<InternalRow,InternalRow> tableState

Constructor Detail

PrimaryKeyLookupTable

public PrimaryKeyLookupTable(FullCacheLookupTable.Context context,
                             long lruCacheSize,
                             List<String> joinKey)

Method Detail

open

public void open()
          throws Exception

Throws:

Exception

createTableState

protected void createTableState()
                         throws IOException

Throws:

IOException

innerGet

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

Specified by:

innerGet in class FullCacheLookupTable

Throws:

IOException

refreshRow

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

Specified by:

refreshRow in class FullCacheLookupTable

Throws:

IOException

toKeyBytes

public byte[] toKeyBytes(InternalRow row)
                  throws IOException

Specified by:

toKeyBytes in class FullCacheLookupTable

Throws:

IOException

toValueBytes

public byte[] toValueBytes(InternalRow row)
                    throws IOException

Specified by:

toValueBytes in class FullCacheLookupTable

Throws:

IOException

createBulkLoader

public FullCacheLookupTable.TableBulkLoader createBulkLoader()

Specified by:

createBulkLoader in class FullCacheLookupTable

bulkLoadWritePlus

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

Throws:

IOException