public class HiveCatalogLock extends Object implements CatalogLock
CatalogLock
.CatalogLock.Factory
Constructor and Description |
---|
HiveCatalogLock(HiveMetastoreClientWrapper client,
long checkMaxSleep,
long acquireTimeout) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
static CatalogLock.Factory |
createFactory(HiveConf hiveConf)
Create a hive lock factory.
|
<T> T |
runWithLock(String database,
String table,
Callable<T> callable)
Run with catalog lock.
|
public HiveCatalogLock(HiveMetastoreClientWrapper 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(HiveConf hiveConf)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.