public class JdbcCatalogLock extends Object implements CatalogLock
Constructor and Description |
---|
JdbcCatalogLock(JdbcClientPool connections,
String catalogKey,
long checkMaxSleep,
long acquireTimeout) |
Modifier and Type | Method and Description |
---|---|
static long |
acquireTimeout(Map<String,String> conf) |
static long |
checkMaxSleep(Map<String,String> conf) |
void |
close() |
<T> T |
runWithLock(String database,
String table,
Callable<T> callable)
Run with catalog lock.
|
public JdbcCatalogLock(JdbcClientPool connections, String catalogKey, 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() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.