public class HiveCatalogLock extends Object implements CatalogLock
CatalogLock
.Constructor and Description |
---|
HiveCatalogLock(ClientPool<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException> clients,
long checkMaxSleep,
long acquireTimeout) |
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.
|
public HiveCatalogLock(ClientPool<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException> clients, long checkMaxSleep, long acquireTimeout)
public <T> T runWithLock(String database, String table, Callable<T> callable) throws Exception
CatalogLock
runWithLock
in interface CatalogLock
Exception
public void close()
close
in interface Closeable
close
in interface AutoCloseable
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)
public static long checkMaxSleep(org.apache.hadoop.hive.conf.HiveConf conf)
public static long acquireTimeout(org.apache.hadoop.hive.conf.HiveConf conf)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.