org.apache.paimon.jdbc

Class SqlLiteDistributedLockDialect

java.lang.Object

org.apache.paimon.jdbc.AbstractDistributedLockDialect

org.apache.paimon.jdbc.SqlLiteDistributedLockDialect

All Implemented Interfaces:

JdbcDistributedLockDialect

public class SqlLiteDistributedLockDialect
extends AbstractDistributedLockDialect

Distributed lock implementation based on sqlite table.

Constructor Summary

Constructors

Constructor and Description
SqlLiteDistributedLockDialect()

Method Summary

Modifier and Type	Method and Description
String	getCreateTableSql()
String	getLockAcquireSql()
String	getReleaseLockSql()
String	getTryReleaseTimedOutLock()

Methods inherited from class org.apache.paimon.jdbc.AbstractDistributedLockDialect

createTable, lockAcquire, releaseLock, tryReleaseTimedOutLock

Methods inherited from class java.lang.Object

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

Constructor Detail

SqlLiteDistributedLockDialect

public SqlLiteDistributedLockDialect()

Method Detail

getCreateTableSql

public String getCreateTableSql()

Specified by:

getCreateTableSql in class AbstractDistributedLockDialect

getLockAcquireSql

public String getLockAcquireSql()

Specified by:

getLockAcquireSql in class AbstractDistributedLockDialect

getReleaseLockSql

public String getReleaseLockSql()

Specified by:

getReleaseLockSql in class AbstractDistributedLockDialect

getTryReleaseTimedOutLock

public String getTryReleaseTimedOutLock()

Specified by:

getTryReleaseTimedOutLock in class AbstractDistributedLockDialect