org.apache.paimon.flink.lookup

Class DynamicPartitionLoader

java.lang.Object

org.apache.paimon.flink.lookup.PartitionLoader

org.apache.paimon.flink.lookup.DynamicPartitionLoader

All Implemented Interfaces:

Serializable

public class DynamicPartitionLoader
extends PartitionLoader

Dynamic partition for lookup.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.paimon.flink.lookup.PartitionLoader

partitions, table

Method Summary

Modifier and Type	Method and Description
boolean	checkRefresh()
void	open()

Methods inherited from class org.apache.paimon.flink.lookup.PartitionLoader

addPartitionKeysTo, createSpecificPartFilter, of, 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()

Overrides:

open in class PartitionLoader

checkRefresh

public boolean checkRefresh()

Specified by:

checkRefresh in class PartitionLoader

Returns:

true if partition changed.