org.apache.paimon.flink.lookup

Class FullCacheLookupTable.Context

java.lang.Object

org.apache.paimon.flink.lookup.FullCacheLookupTable.Context

Enclosing class:

FullCacheLookupTable

public static class FullCacheLookupTable.Context
extends Object

Context for LookupTable.

Field Summary

Fields

Modifier and Type	Field and Description
List<String>	joinKey
Predicate	projectedPredicate
int[]	projection
Set<Integer>	requiredCachedBucketIds
LookupFileStoreTable	table
Predicate	tablePredicate
File	tempPath

Constructor Summary

Constructors

Constructor and Description
Context(FileStoreTable table, int[] projection, Predicate tablePredicate, Predicate projectedPredicate, File tempPath, List<String> joinKey, Set<Integer> requiredCachedBucketIds)

Method Summary

Modifier and Type	Method and Description
FullCacheLookupTable.Context	copy(int[] newProjection)

Methods inherited from class java.lang.Object

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

Field Detail

table

public final LookupFileStoreTable table

projection

public final int[] projection

tablePredicate

@Nullable
public final Predicate tablePredicate

projectedPredicate

@Nullable
public final Predicate projectedPredicate

tempPath

public final File tempPath

joinKey

public final List<String> joinKey

requiredCachedBucketIds

public final Set<Integer> requiredCachedBucketIds

Constructor Detail

Context

public Context(FileStoreTable table,
               int[] projection,
               @Nullable
               Predicate tablePredicate,
               @Nullable
               Predicate projectedPredicate,
               File tempPath,
               List<String> joinKey,
               @Nullable
               Set<Integer> requiredCachedBucketIds)

Method Detail

copy

public FullCacheLookupTable.Context copy(int[] newProjection)