org.apache.flink.table.catalog

Interface CatalogLock

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

HiveCatalogLock

Deprecated.

This interface will be removed soon. Please see FLIP-346 for more details.

@Deprecated
 @Internal
public interface CatalogLock
extends Closeable

An interface that allows source and sink to use global lock to some transaction-related things.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	CatalogLock.Factory Deprecated. This interface will be removed soon. Please see FLIP-346 for more details.

Method Summary

Modifier and Type	Method and Description
<T> T	runWithLock(String database, String table, Callable<T> callable) Deprecated. Run with catalog lock.

Methods inherited from interface java.io.Closeable

close

Method Detail

runWithLock

<T> T runWithLock(String database,
                  String table,
                  Callable<T> callable)
           throws Exception

Deprecated.

Run with catalog lock. The caller should tell catalog the database and table name.

Throws:

Exception