Class JdbcLockFactory
- java.lang.Object
-
- org.apache.iceberg.flink.maintenance.operator.JdbcLockFactory
-
- All Implemented Interfaces:
java.io.Closeable
,java.io.Serializable
,java.lang.AutoCloseable
,TriggerLockFactory
public class JdbcLockFactory extends java.lang.Object implements TriggerLockFactory
JDBC table backed implementation of theTriggerLockFactory
.- See Also:
- Serialized Form
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.iceberg.flink.maintenance.operator.TriggerLockFactory
TriggerLockFactory.Lock
-
-
Constructor Summary
Constructors Constructor Description JdbcLockFactory(java.lang.String uri, java.lang.String lockId, java.util.Map<java.lang.String,java.lang.String> properties)
Creates a newTriggerLockFactory
.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
TriggerLockFactory.Lock
createLock()
TriggerLockFactory.Lock
createRecoveryLock()
void
open()
-
-
-
Constructor Detail
-
JdbcLockFactory
public JdbcLockFactory(java.lang.String uri, java.lang.String lockId, java.util.Map<java.lang.String,java.lang.String> properties)
Creates a newTriggerLockFactory
. The lockId should be unique between the users of the same uri.- Parameters:
uri
- of the jdbc connectionlockId
- which should indentify the job and the tableproperties
- used for creating the jdbc connection pool
-
-
Method Detail
-
open
public void open()
- Specified by:
open
in interfaceTriggerLockFactory
-
createLock
public TriggerLockFactory.Lock createLock()
- Specified by:
createLock
in interfaceTriggerLockFactory
-
createRecoveryLock
public TriggerLockFactory.Lock createRecoveryLock()
- Specified by:
createRecoveryLock
in interfaceTriggerLockFactory
-
close
public void close() throws java.io.IOException
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
- Throws:
java.io.IOException
-
-