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) |
FileStoreCommit |
FileStore.newCommit(String commitUser,
List<CommitCallback> callbacks) |
Modifier and Type | Class and Description |
---|---|
class |
FileStoreCommitImpl
Default implementation of
FileStoreCommit . |
Modifier and Type | Method and Description |
---|---|
FileStoreCommit |
FileStoreCommitImpl.ignoreEmptyCommit(boolean ignoreEmptyCommit) |
FileStoreCommit |
FileStoreCommit.ignoreEmptyCommit(boolean ignoreEmptyCommit) |
FileStoreCommit |
FileStoreCommitImpl.withLock(Lock lock) |
FileStoreCommit |
FileStoreCommit.withLock(Lock lock)
With global lock.
|
FileStoreCommit |
FileStoreCommitImpl.withMetrics(CommitMetrics metrics) |
FileStoreCommit |
FileStoreCommit.withMetrics(CommitMetrics metrics)
With metrics to measure commits.
|
FileStoreCommit |
FileStoreCommitImpl.withPartitionExpire(PartitionExpire partitionExpire) |
FileStoreCommit |
FileStoreCommit.withPartitionExpire(PartitionExpire partitionExpire) |
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) |
Modifier and Type | Method and Description |
---|---|
FileStoreCommit |
PrivilegedFileStore.newCommit(String commitUser) |
FileStoreCommit |
PrivilegedFileStore.newCommit(String commitUser,
List<CommitCallback> callbacks) |
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.