org.apache.paimon.flink.lookup

Class NoPrimaryKeyLookupTable

java.lang.Object

org.apache.paimon.flink.lookup.FullCacheLookupTable

org.apache.paimon.flink.lookup.NoPrimaryKeyLookupTable

All Implemented Interfaces:

Closeable, AutoCloseable, LookupTable

public class NoPrimaryKeyLookupTable
extends FullCacheLookupTable

A LookupTable for table without primary 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.FullCacheLookupTable

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
FullCacheLookupTable.TableBulkLoader	createBulkLoader()
List<InternalRow>	innerGet(InternalRow key)
void	open()
void	refresh(Iterator<InternalRow> incremental)
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, specificPartitionFilter, specifyCacheRowFilter

Methods inherited from class java.lang.Object

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

Constructor Detail

NoPrimaryKeyLookupTable

public NoPrimaryKeyLookupTable(FullCacheLookupTable.Context context,
                               long lruCacheSize)

Method Detail

open

public void open()
          throws Exception

Throws:

Exception

innerGet

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

Specified by:

innerGet in class FullCacheLookupTable

Throws:

IOException

refresh

public void refresh(Iterator<InternalRow> incremental)
             throws IOException

Overrides:

refresh 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