org.apache.paimon.hive

Class HiveCatalogLock

java.lang.Object

org.apache.paimon.hive.HiveCatalogLock

All Implemented Interfaces:

Closeable, AutoCloseable, CatalogLock

public class HiveCatalogLock
extends Object
implements CatalogLock

Hive CatalogLock.

Constructor Summary

Constructors

Constructor and Description
HiveCatalogLock(ClientPool<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException> clients, long checkMaxSleep, long acquireTimeout)

Method Summary

Modifier and Type	Method and Description
static long	acquireTimeout(org.apache.hadoop.hive.conf.HiveConf conf)
static long	checkMaxSleep(org.apache.hadoop.hive.conf.HiveConf conf)
void	close()
static ClientPool<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException>	createClients(org.apache.hadoop.hive.conf.HiveConf conf, Options options, String clientClassName)
<T> T	runWithLock(String database, String table, Callable<T> callable) 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(ClientPool<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException> clients,
                       long checkMaxSleep,
                       long acquireTimeout)

Method Detail

runWithLock

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

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()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

createClients

public static ClientPool<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException> createClients(org.apache.hadoop.hive.conf.HiveConf conf,
                                                                                                                       Options options,
                                                                                                                       String clientClassName)

checkMaxSleep

public static long checkMaxSleep(org.apache.hadoop.hive.conf.HiveConf conf)

acquireTimeout

public static long acquireTimeout(org.apache.hadoop.hive.conf.HiveConf conf)