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 and Description
BaseLockManager()

Method Summary

Modifier and Type	Method and 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

Constructor Detail

BaseLockManager

public BaseLockManager()

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 interface LockManager

Parameters:

properties - catalog properties

close

public void close()
           throws java.lang.Exception

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.Exception