org.apache.flink.table.catalog.hive

Class HiveCatalogLock

java.lang.Object

org.apache.flink.table.catalog.hive.HiveCatalogLock

All Implemented Interfaces:

Closeable, AutoCloseable, CatalogLock

Deprecated.

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

@Deprecated
public class HiveCatalogLock
extends Object
implements CatalogLock

Hive CatalogLock.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.catalog.CatalogLock

CatalogLock.Factory

Constructor Summary

Constructors

Constructor and Description
HiveCatalogLock(HiveMetastoreClientWrapper client, long checkMaxSleep, long acquireTimeout) Deprecated.

Method Summary

Modifier and Type	Method and Description
void	close() Deprecated.
static CatalogLock.Factory	createFactory(HiveConf hiveConf) Deprecated. Create a hive lock factory.
<T> T	runWithLock(String database, String table, Callable<T> callable) Deprecated. Run with catalog lock.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HiveCatalogLock

public HiveCatalogLock(HiveMetastoreClientWrapper client,
                       long checkMaxSleep,
                       long acquireTimeout)

Deprecated.

Method Detail

runWithLock

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

Deprecated.

Description copied from interface: CatalogLock

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

Specified by:

runWithLock in interface CatalogLock

Throws:

Exception

close

public void close()

Deprecated.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

createFactory

public static CatalogLock.Factory createFactory(HiveConf hiveConf)

Deprecated.

Create a hive lock factory.