| 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 |
|---|---|
FileStoreCommit |
FileStoreCommitImpl.withLock(Lock lock) |
PartitionExpire |
PartitionExpire.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–2025 The Apache Software Foundation. All rights reserved.