public interface Lock extends AutoCloseable
Modifier and Type | Interface and Description |
---|---|
static class |
Lock.CatalogLockFactory
A
Lock.Factory creating lock from catalog. |
static class |
Lock.CatalogLockImpl
A
Lock to wrap CatalogLock . |
static class |
Lock.EmptyFactory
A
Lock.Factory creating empty lock. |
static class |
Lock.EmptyLock
An empty lock.
|
static interface |
Lock.Factory
A factory to create
Lock . |
Modifier and Type | Method and Description |
---|---|
static Lock.Factory |
emptyFactory() |
static Lock.Factory |
factory(CatalogLock.Factory lockFactory,
org.apache.flink.table.catalog.ObjectPath tablePath) |
static Lock |
fromCatalog(CatalogLock lock,
org.apache.flink.table.catalog.ObjectPath tablePath) |
<T> T |
runWithLock(Callable<T> callable)
Run with lock.
|
close
<T> T runWithLock(Callable<T> callable) throws Exception
Exception
static Lock.Factory factory(@Nullable CatalogLock.Factory lockFactory, org.apache.flink.table.catalog.ObjectPath tablePath)
static Lock.Factory emptyFactory()
static Lock fromCatalog(CatalogLock lock, org.apache.flink.table.catalog.ObjectPath tablePath)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.