org.apache.paimon.partition

Class PartitionExpireStrategy

java.lang.Object

org.apache.paimon.partition.PartitionExpireStrategy

Direct Known Subclasses:

PartitionUpdateTimeExpireStrategy, PartitionValuesTimeExpireStrategy

public abstract class PartitionExpireStrategy
extends Object

Strategy for partition expiration.

Field Summary

Fields

Modifier and Type	Field and Description
protected List<String>	partitionKeys

Constructor Summary

Constructors

Constructor and Description
PartitionExpireStrategy(RowType partitionType)

Method Summary

Modifier and Type	Method and Description
Object[]	convertPartition(BinaryRow partition)
static PartitionExpireStrategy	createPartitionExpireStrategy(CoreOptions options, RowType partitionType)
abstract List<PartitionEntry>	selectExpiredPartitions(FileStoreScan scan, java.time.LocalDateTime expirationTime)
Map<String,String>	toPartitionString(Object[] array)
List<String>	toPartitionValue(Object[] array)

Methods inherited from class java.lang.Object

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

Field Detail

partitionKeys

protected final List<String> partitionKeys

Constructor Detail

PartitionExpireStrategy

public PartitionExpireStrategy(RowType partitionType)

Method Detail

toPartitionString

public Map<String,String> toPartitionString(Object[] array)

toPartitionValue

public List<String> toPartitionValue(Object[] array)

convertPartition

public Object[] convertPartition(BinaryRow partition)

selectExpiredPartitions

public abstract List<PartitionEntry> selectExpiredPartitions(FileStoreScan scan,
                                                             java.time.LocalDateTime expirationTime)

createPartitionExpireStrategy

public static PartitionExpireStrategy createPartitionExpireStrategy(CoreOptions options,
                                                                    RowType partitionType)