public class PartitionExpire extends Object
Constructor and Description |
---|
PartitionExpire(org.apache.flink.table.types.logical.RowType partitionType,
java.time.Duration expirationTime,
java.time.Duration checkInterval,
String timePattern,
String timeFormatter,
FileStoreScan scan,
FileStoreCommit commit) |
public PartitionExpire(org.apache.flink.table.types.logical.RowType partitionType, java.time.Duration expirationTime, java.time.Duration checkInterval, String timePattern, String timeFormatter, FileStoreScan scan, FileStoreCommit commit)
public PartitionExpire withLock(Lock lock)
public void expire()
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.