org.apache.paimon.jdbc

Class MysqlDistributedLockDialect

java.lang.Object

org.apache.paimon.jdbc.AbstractDistributedLockDialect

org.apache.paimon.jdbc.MysqlDistributedLockDialect

All Implemented Interfaces:

JdbcDistributedLockDialect

public class MysqlDistributedLockDialect
extends AbstractDistributedLockDialect

Distributed lock implementation based on mysql table.

Constructor Summary

Constructors

Constructor and Description
MysqlDistributedLockDialect()

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

MysqlDistributedLockDialect

public MysqlDistributedLockDialect()

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