Package org.apache.iceberg.util
Class LockManagers.BaseLockManager
- java.lang.Object
-
- org.apache.iceberg.util.LockManagers.BaseLockManager
-
- All Implemented Interfaces:
java.lang.AutoCloseable
,LockManager
- Direct Known Subclasses:
DynamoDbLockManager
- Enclosing class:
- LockManagers
public abstract static class LockManagers.BaseLockManager extends java.lang.Object implements LockManager
-
-
Constructor Summary
Constructors Constructor Description BaseLockManager()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description long
acquireIntervalMs()
long
acquireTimeoutMs()
void
close()
long
heartbeatIntervalMs()
int
heartbeatThreads()
long
heartbeatTimeoutMs()
void
initialize(java.util.Map<java.lang.String,java.lang.String> properties)
Initialize lock manager from catalog properties.java.util.concurrent.ScheduledExecutorService
scheduler()
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.iceberg.LockManager
acquire, release
-
-
-
-
Method Detail
-
heartbeatTimeoutMs
public long heartbeatTimeoutMs()
-
heartbeatIntervalMs
public long heartbeatIntervalMs()
-
acquireIntervalMs
public long acquireIntervalMs()
-
acquireTimeoutMs
public long acquireTimeoutMs()
-
heartbeatThreads
public int heartbeatThreads()
-
scheduler
public java.util.concurrent.ScheduledExecutorService scheduler()
-
initialize
public void initialize(java.util.Map<java.lang.String,java.lang.String> properties)
Description copied from interface:LockManager
Initialize lock manager from catalog properties.- Specified by:
initialize
in interfaceLockManager
- Parameters:
properties
- catalog properties
-
close
public void close() throws java.lang.Exception
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Throws:
java.lang.Exception
-
-