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, MetastoreClient metastoreClient)
PartitionExpire(java.time.Duration expirationTime, java.time.Duration checkInterval, PartitionExpireStrategy strategy, FileStoreScan scan, FileStoreCommit commit, MetastoreClient metastoreClient, boolean endInputCheckPartitionExpire)

Method Summary

Modifier and Type	Method and Description
List<Map<String,String>>	expire(long commitIdentifier)
boolean	isValueAllExpired(Collection<BinaryRow> partitions)
boolean	isValueExpiration()
PartitionExpire	withLock(Lock lock)
PartitionExpire	withMaxExpires(int maxExpires)

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
                       MetastoreClient metastoreClient,
                       boolean endInputCheckPartitionExpire)

PartitionExpire

public PartitionExpire(java.time.Duration expirationTime,
                       java.time.Duration checkInterval,
                       PartitionExpireStrategy strategy,
                       FileStoreScan scan,
                       FileStoreCommit commit,
                       @Nullable
                       MetastoreClient metastoreClient)

Method Detail

withLock

public PartitionExpire withLock(Lock lock)

withMaxExpires

public PartitionExpire withMaxExpires(int maxExpires)

expire

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

isValueExpiration

public boolean isValueExpiration()

isValueAllExpired

public boolean isValueAllExpired(Collection<BinaryRow> partitions)