org.apache.paimon.operation

Class PartitionExpire

java.lang.Object

org.apache.paimon.operation.PartitionExpire

public class PartitionExpire
extends Object

Expire partitions.

Constructor Summary

Constructors

Constructor and Description
PartitionExpire(java.time.Duration expirationTime, java.time.Duration checkInterval, PartitionExpireStrategy strategy, FileStoreScan scan, FileStoreCommit commit, PartitionHandler partitionHandler, boolean endInputCheckPartitionExpire, int maxExpireNum)
PartitionExpire(java.time.Duration expirationTime, java.time.Duration checkInterval, PartitionExpireStrategy strategy, FileStoreScan scan, FileStoreCommit commit, PartitionHandler partitionHandler, int maxExpireNum)

Method Summary

Modifier and Type	Method and Description
List<Map<String,String>>	expire(long commitIdentifier)
boolean	isValueAllExpired(Collection<BinaryRow> partitions)
boolean	isValueExpiration()

Methods inherited from class java.lang.Object

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

Constructor Detail

PartitionExpire

public PartitionExpire(java.time.Duration expirationTime,
                       java.time.Duration checkInterval,
                       PartitionExpireStrategy strategy,
                       FileStoreScan scan,
                       FileStoreCommit commit,
                       @Nullable
                       PartitionHandler partitionHandler,
                       boolean endInputCheckPartitionExpire,
                       int maxExpireNum)

PartitionExpire

public PartitionExpire(java.time.Duration expirationTime,
                       java.time.Duration checkInterval,
                       PartitionExpireStrategy strategy,
                       FileStoreScan scan,
                       FileStoreCommit commit,
                       @Nullable
                       PartitionHandler partitionHandler,
                       int maxExpireNum)

Method Detail

expire

public List<Map<String,String>> expire(long commitIdentifier)

isValueExpiration

public boolean isValueExpiration()

isValueAllExpired

public boolean isValueAllExpired(Collection<BinaryRow> partitions)