| Package | Description |
|---|---|
| org.apache.paimon | |
| org.apache.paimon.operation | |
| org.apache.paimon.privilege | |
| org.apache.paimon.table.sink |
| Modifier and Type | Method and Description |
|---|---|
FileStoreCommit |
FileStore.newCommit(String commitUser,
FileStoreTable table) |
| Modifier and Type | Class and Description |
|---|---|
class |
FileStoreCommitImpl
Default implementation of
FileStoreCommit. |
| Modifier and Type | Method and Description |
|---|---|
FileStoreCommit |
FileStoreCommit.ignoreEmptyCommit(boolean ignoreEmptyCommit) |
FileStoreCommit |
FileStoreCommitImpl.ignoreEmptyCommit(boolean ignoreEmptyCommit) |
FileStoreCommit |
FileStoreCommit.withMetrics(CommitMetrics metrics)
With metrics to measure commits.
|
FileStoreCommit |
FileStoreCommitImpl.withMetrics(CommitMetrics metrics) |
FileStoreCommit |
FileStoreCommit.withPartitionExpire(PartitionExpire partitionExpire) |
FileStoreCommit |
FileStoreCommitImpl.withPartitionExpire(PartitionExpire partitionExpire) |
| 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) |
| Modifier and Type | Method and Description |
|---|---|
FileStoreCommit |
PrivilegedFileStore.newCommit(String commitUser,
FileStoreTable table) |
| Constructor and Description |
|---|
TableCommitImpl(FileStoreCommit commit,
Runnable expireSnapshots,
PartitionExpire partitionExpire,
TagAutoManager tagAutoManager,
java.time.Duration consumerExpireTime,
ConsumerManager consumerManager,
CoreOptions.ExpireExecutionMode expireExecutionMode,
String tableName,
boolean forceCreatingSnapshot) |
Copyright © 2023–2025 The Apache Software Foundation. All rights reserved.