org.apache.paimon.jdbc

Class AbstractDistributedLockDialect

java.lang.Object

org.apache.paimon.jdbc.AbstractDistributedLockDialect

All Implemented Interfaces:

JdbcDistributedLockDialect

Direct Known Subclasses:

MysqlDistributedLockDialect, SqlLiteDistributedLockDialect

public abstract class AbstractDistributedLockDialect
extends Object
implements JdbcDistributedLockDialect

Jdbc distributed lock interface.

Constructor Summary

Constructors

Constructor and Description
AbstractDistributedLockDialect()

Method Summary

Modifier and Type	Method and Description
void	createTable(JdbcClientPool connections, Options options)
abstract String	getCreateTableSql()
abstract String	getLockAcquireSql()
abstract String	getReleaseLockSql()
abstract String	getTryReleaseTimedOutLock()
boolean	lockAcquire(JdbcClientPool connections, String lockId, long timeoutMillSeconds)
boolean	releaseLock(JdbcClientPool connections, String lockId)
int	tryReleaseTimedOutLock(JdbcClientPool connections, String lockId)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractDistributedLockDialect

public AbstractDistributedLockDialect()

Method Detail

createTable

public void createTable(JdbcClientPool connections,
                        Options options)
                 throws SQLException,
                        InterruptedException

Specified by:

createTable in interface JdbcDistributedLockDialect

Throws:

SQLException

InterruptedException

getCreateTableSql

public abstract String getCreateTableSql()

lockAcquire

public boolean lockAcquire(JdbcClientPool connections,
                           String lockId,
                           long timeoutMillSeconds)
                    throws SQLException,
                           InterruptedException

Specified by:

lockAcquire in interface JdbcDistributedLockDialect

Throws:

SQLException

InterruptedException

getLockAcquireSql

public abstract String getLockAcquireSql()

releaseLock

public boolean releaseLock(JdbcClientPool connections,
                           String lockId)
                    throws SQLException,
                           InterruptedException

Specified by:

releaseLock in interface JdbcDistributedLockDialect

Throws:

SQLException

InterruptedException

getReleaseLockSql

public abstract String getReleaseLockSql()

tryReleaseTimedOutLock

public int tryReleaseTimedOutLock(JdbcClientPool connections,
                                  String lockId)
                           throws SQLException,
                                  InterruptedException

Specified by:

tryReleaseTimedOutLock in interface JdbcDistributedLockDialect

Throws:

SQLException

InterruptedException

getTryReleaseTimedOutLock

public abstract String getTryReleaseTimedOutLock()