public class HiveCatalogLock extends Object implements CatalogLock
CatalogLock
.CatalogLock.Factory
Constructor and Description |
---|
HiveCatalogLock(org.apache.hadoop.hive.metastore.IMetaStoreClient client,
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 CatalogLock.Factory |
createFactory(org.apache.hadoop.hive.conf.HiveConf hiveConf,
String clientClassName)
Create a hive lock factory.
|
<T> T |
runWithLock(String database,
String table,
Callable<T> callable)
Run with catalog lock.
|
public HiveCatalogLock(org.apache.hadoop.hive.metastore.IMetaStoreClient client, 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 CatalogLock.Factory createFactory(org.apache.hadoop.hive.conf.HiveConf hiveConf, 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 © 2019–2023 The Apache Software Foundation. All rights reserved.