Package | Description |
---|---|
org.apache.paimon.operation | |
org.apache.paimon.schema | |
org.apache.paimon.table.sink |
Modifier and Type | Class and Description |
---|---|
static class |
Lock.CatalogLockImpl
A
Lock to wrap CatalogLock . |
static class |
Lock.EmptyLock
An empty lock.
|
Modifier and Type | Method and Description |
---|---|
Lock |
Lock.Factory.create() |
Lock |
Lock.LockFactory.create() |
Lock |
Lock.EmptyFactory.create() |
static Lock |
Lock.fromCatalog(CatalogLock lock,
Identifier tablePath) |
Modifier and Type | Method and Description |
---|---|
PartitionExpire |
PartitionExpire.withLock(Lock lock) |
FileStoreCommit |
FileStoreCommitImpl.withLock(Lock lock) |
FileStoreCommit |
FileStoreCommit.withLock(Lock lock)
With global lock.
|
Modifier and Type | Method and Description |
---|---|
SchemaManager |
SchemaManager.withLock(Lock lock) |
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.