org.apache.iceberg.util

Class LockManagers.BaseLockManager

java.lang.Object

org.apache.iceberg.util.LockManagers.BaseLockManager

All Implemented Interfaces:

java.lang.AutoCloseable, LockManager

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()
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

Methods inherited from interface java.lang.AutoCloseable

close

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