org.apache.paimon.jdbc

Class JdbcCatalogLock

java.lang.Object

org.apache.paimon.jdbc.JdbcCatalogLock

All Implemented Interfaces:

Closeable, AutoCloseable, CatalogLock

public class JdbcCatalogLock
extends Object
implements CatalogLock

Jdbc catalog lock.

Constructor Summary

Constructors

Constructor and Description
JdbcCatalogLock(JdbcClientPool connections, String catalogKey, long checkMaxSleep, long acquireTimeout)

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JdbcCatalogLock

public JdbcCatalogLock(JdbcClientPool connections,
                       String catalogKey,
                       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()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

checkMaxSleep

public static long checkMaxSleep(Map<String,String> conf)

acquireTimeout

public static long acquireTimeout(Map<String,String> conf)