org.apache.paimon.flink.lookup

Class DynamicPartitionLoader

java.lang.Object

org.apache.paimon.flink.lookup.DynamicPartitionLoader

All Implemented Interfaces:

Serializable

public class DynamicPartitionLoader
extends Object
implements Serializable

Dynamic partition for lookup.

See Also:

Serialized Form

Method Summary

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

Methods inherited from class java.lang.Object

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

Method Detail

open

public void open()

addPartitionKeysTo

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

partitions

public List<BinaryRow> partitions()

createSpecificPartFilter

public Predicate createSpecificPartFilter()

checkRefresh

public boolean checkRefresh()

Returns:

true if partition changed.

of

@Nullable
public static DynamicPartitionLoader of(Table table)