Package | Description |
---|---|
org.apache.flink.table.store.file.operation | |
org.apache.flink.table.store.file.schema | |
org.apache.flink.table.store.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.CatalogLockFactory.create() |
Lock |
Lock.EmptyFactory.create() |
static Lock |
Lock.fromCatalog(CatalogLock lock,
org.apache.flink.table.catalog.ObjectPath tablePath) |
Modifier and Type | Method and Description |
---|---|
FileStoreExpire |
FileStoreExpireImpl.withLock(Lock lock) |
FileStoreCommit |
FileStoreCommit.withLock(Lock lock)
With global lock.
|
FileStoreExpire |
FileStoreExpire.withLock(Lock lock)
With global lock.
|
PartitionExpire |
PartitionExpire.withLock(Lock lock) |
FileStoreCommit |
FileStoreCommitImpl.withLock(Lock lock) |
Modifier and Type | Method and Description |
---|---|
SchemaManager |
SchemaManager.withLock(Lock lock) |
Modifier and Type | Method and Description |
---|---|
TableCommit |
TableCommit.withLock(Lock lock) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.