org.apache.paimon.flink.lookup

Class FullCacheLookupTable

java.lang.Object

org.apache.paimon.flink.lookup.FullCacheLookupTable

All Implemented Interfaces:

Closeable, AutoCloseable, LookupTable

Direct Known Subclasses:

NoPrimaryKeyLookupTable, PrimaryKeyLookupTable

public abstract class FullCacheLookupTable
extends Object
implements LookupTable

Lookup table of full cache.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FullCacheLookupTable.Context Context for LookupTable.
static interface	FullCacheLookupTable.TableBulkLoader Bulk loader for the table.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	appendUdsFieldNumber
protected FullCacheLookupTable.Context	context
protected Object	lock
protected RowType	projectedType
protected boolean	refreshAsync
protected RocksDBStateFactory	stateFactory
protected FieldsComparator	userDefinedSeqComparator

Constructor Summary

Constructors

Constructor and Description
FullCacheLookupTable(FullCacheLookupTable.Context context)

Method Summary

Modifier and Type	Method and Description
protected void	bootstrap()
void	close()
abstract FullCacheLookupTable.TableBulkLoader	createBulkLoader()
List<InternalRow>	get(InternalRow key)
Future<?>	getRefreshFuture()
protected void	init()
abstract List<InternalRow>	innerGet(InternalRow key)
Predicate	projectedPredicate()
void	refresh()
void	refresh(Iterator<InternalRow> input)
protected abstract void	refreshRow(InternalRow row, Predicate predicate)
void	specificPartitionFilter(Predicate filter)
void	specifyCacheRowFilter(Filter<InternalRow> filter)
abstract byte[]	toKeyBytes(InternalRow row)
abstract byte[]	toValueBytes(InternalRow row)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.paimon.flink.lookup.LookupTable

open

Field Detail

lock

protected final Object lock

context

protected final FullCacheLookupTable.Context context

projectedType

protected final RowType projectedType

refreshAsync

protected final boolean refreshAsync

userDefinedSeqComparator

@Nullable
protected final FieldsComparator userDefinedSeqComparator

appendUdsFieldNumber

protected final int appendUdsFieldNumber

stateFactory

protected RocksDBStateFactory stateFactory

Constructor Detail

FullCacheLookupTable

public FullCacheLookupTable(FullCacheLookupTable.Context context)

Method Detail

specificPartitionFilter

public void specificPartitionFilter(Predicate filter)

Specified by:

specificPartitionFilter in interface LookupTable

specifyCacheRowFilter

public void specifyCacheRowFilter(Filter<InternalRow> filter)

Specified by:

specifyCacheRowFilter in interface LookupTable

init

protected void init()
             throws Exception

Throws:

Exception

bootstrap

protected void bootstrap()
                  throws Exception

Throws:

Exception

refresh

public void refresh()
             throws Exception

Specified by:

refresh in interface LookupTable

Throws:

Exception

get

public final List<InternalRow> get(InternalRow key)
                            throws IOException

Specified by:

get in interface LookupTable

Throws:

IOException

refresh

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

Throws:

IOException

innerGet

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

Throws:

IOException

refreshRow

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

Throws:

IOException

projectedPredicate

@Nullable
public Predicate projectedPredicate()

toKeyBytes

public abstract byte[] toKeyBytes(InternalRow row)
                           throws IOException

Throws:

IOException

toValueBytes

public abstract byte[] toValueBytes(InternalRow row)
                             throws IOException

Throws:

IOException

createBulkLoader

public abstract FullCacheLookupTable.TableBulkLoader createBulkLoader()

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

getRefreshFuture

@VisibleForTesting
public Future<?> getRefreshFuture()