org.apache.paimon.flink.lookup

Class StaticPartitionLoader

java.lang.Object

org.apache.paimon.flink.lookup.PartitionLoader

org.apache.paimon.flink.lookup.StaticPartitionLoader

All Implemented Interfaces:

Serializable

public class StaticPartitionLoader
extends PartitionLoader

PartitionLoader for specified static partitions.

See Also:

Serialized Form

Field Summary

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

partitions, table

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	StaticPartitionLoader(FileStoreTable table, List<Map<String,String>> scanPartitions)

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

Constructor Detail

StaticPartitionLoader

protected StaticPartitionLoader(FileStoreTable table,
                                List<Map<String,String>> scanPartitions)

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.