Package | Description |
---|---|
org.apache.paimon | |
org.apache.paimon.operation | |
org.apache.paimon.privilege | |
org.apache.paimon.table.sink |
Modifier and Type | Method and Description |
---|---|
PartitionExpire |
FileStore.newPartitionExpire(String commitUser) |
Modifier and Type | Method and Description |
---|---|
PartitionExpire |
PartitionExpire.withLock(Lock lock) |
PartitionExpire |
PartitionExpire.withMaxExpires(int maxExpires) |
Modifier and Type | Method and Description |
---|---|
FileStoreCommit |
FileStoreCommitImpl.withPartitionExpire(PartitionExpire partitionExpire) |
FileStoreCommit |
FileStoreCommit.withPartitionExpire(PartitionExpire partitionExpire) |
Modifier and Type | Method and Description |
---|---|
PartitionExpire |
PrivilegedFileStore.newPartitionExpire(String commitUser) |
Constructor and Description |
---|
TableCommitImpl(FileStoreCommit commit,
Runnable expireSnapshots,
PartitionExpire partitionExpire,
TagAutoManager tagAutoManager,
Lock lock,
java.time.Duration consumerExpireTime,
ConsumerManager consumerManager,
CoreOptions.ExpireExecutionMode expireExecutionMode,
String tableName,
boolean forceCreatingSnapshot) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.