org.apache.paimon.partition

Class PartitionValuesTimeExpireStrategy

java.lang.Object

org.apache.paimon.partition.PartitionExpireStrategy

org.apache.paimon.partition.PartitionValuesTimeExpireStrategy

public class PartitionValuesTimeExpireStrategy
extends PartitionExpireStrategy

A partition expiration policy that compare the time extracted from the partition with the current time.

Field Summary

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

partitionKeys

Constructor Summary

Constructors

Constructor and Description
PartitionValuesTimeExpireStrategy(CoreOptions options, RowType partitionType)

Method Summary

Modifier and Type	Method and Description
boolean	isExpired(java.time.LocalDateTime expireDateTime, BinaryRow partition)
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

PartitionValuesTimeExpireStrategy

public PartitionValuesTimeExpireStrategy(CoreOptions options,
                                         RowType partitionType)

Method Detail

selectExpiredPartitions

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

Specified by:

selectExpiredPartitions in class PartitionExpireStrategy

isExpired

public boolean isExpired(java.time.LocalDateTime expireDateTime,
                         BinaryRow partition)