org.apache.paimon.jdbc

Interface JdbcDistributedLockDialect

All Known Implementing Classes:

AbstractDistributedLockDialect, MysqlDistributedLockDialect, SqlLiteDistributedLockDialect

public interface JdbcDistributedLockDialect

Jdbc distributed lock interface.

Method Summary

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

Method Detail

createTable

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

Throws:

SQLException

InterruptedException

lockAcquire

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

Throws:

SQLException

InterruptedException

releaseLock

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

Throws:

SQLException

InterruptedException

tryReleaseTimedOutLock

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

Throws:

SQLException

InterruptedException