org.apache.paimon.flink.lookup

Class PartitionLoader

java.lang.Object

org.apache.paimon.flink.lookup.PartitionLoader

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

DynamicPartitionLoader, StaticPartitionLoader

public abstract class PartitionLoader
extends Object
implements Serializable

Specify partitions for lookup tables.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected List<BinaryRow>	partitions
protected FileStoreTable	table

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	PartitionLoader(FileStoreTable table)

Method Summary

Modifier and Type	Method and Description
void	addPartitionKeysTo(List<String> joinKeys, List<String> projectFields)
abstract boolean	checkRefresh()
Predicate	createSpecificPartFilter()
static PartitionLoader	of(FileStoreTable table)
void	open()
List<BinaryRow>	partitions()

Methods inherited from class java.lang.Object

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

Field Detail

table

protected final FileStoreTable table

partitions

protected transient List<BinaryRow> partitions

Constructor Detail

PartitionLoader

protected PartitionLoader(FileStoreTable table)

Method Detail

open

public void open()

partitions

public List<BinaryRow> partitions()

addPartitionKeysTo

public void addPartitionKeysTo(List<String> joinKeys,
                               List<String> projectFields)

createSpecificPartFilter

public Predicate createSpecificPartFilter()

checkRefresh

public abstract boolean checkRefresh()

Returns:

true if partition changed.

of

@Nullable
public static PartitionLoader of(FileStoreTable table)