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()
static DynamicPartitionLoader	of(Table table)
void	open()
BinaryRow	partition()

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)

partition

@Nullable
public BinaryRow partition()

checkRefresh

public boolean checkRefresh()

Returns:

true if partition changed.

of

@Nullable
public static DynamicPartitionLoader of(Table table)