org.apache.paimon.partition

Class PartitionUpdateTimeExpireStrategy

java.lang.Object

org.apache.paimon.partition.PartitionExpireStrategy

org.apache.paimon.partition.PartitionUpdateTimeExpireStrategy

public class PartitionUpdateTimeExpireStrategy
extends PartitionExpireStrategy

A partition expiration policy that compares the last update time of the partition to the current time.

Field Summary

Fields inherited from class org.apache.paimon.partition.PartitionExpireStrategy

partitionKeys

Constructor Summary

Constructors

Constructor and Description
PartitionUpdateTimeExpireStrategy(RowType partitionType)

Method Summary

Modifier and Type	Method and Description
List<PartitionEntry>	selectExpiredPartitions(FileStoreScan scan, java.time.LocalDateTime expirationTime)

Methods inherited from class org.apache.paimon.partition.PartitionExpireStrategy

convertPartition, createPartitionExpireStrategy, toPartitionString

Methods inherited from class java.lang.Object

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

Constructor Detail

PartitionUpdateTimeExpireStrategy

public PartitionUpdateTimeExpireStrategy(RowType partitionType)

Method Detail

selectExpiredPartitions

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

Specified by:

selectExpiredPartitions in class PartitionExpireStrategy