LockManagers.BaseLockManager

java.lang.Object

org.apache.iceberg.util.LockManagers.BaseLockManager

All Implemented Interfaces:: AutoCloseable, LockManager

Direct Known Subclasses:: DynamoDbLockManager

Enclosing class:: LockManagers

public abstract static class LockManagers.BaseLockManager extends Object implements LockManager

Constructor Summary

Constructors

Constructor

Description

BaseLockManager()
Method Summary

Modifier and Type

Method

Description

long

acquireIntervalMs()

long

acquireTimeoutMs()

void

close()

long

heartbeatIntervalMs()

int

heartbeatThreads()

long

heartbeatTimeoutMs()

void

initialize(Map<String,String> properties)

Initialize lock manager from catalog properties.

ScheduledExecutorService

scheduler()

Returns the shared scheduler for lock heartbeats.

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 Details
- BaseLockManager
  
  public BaseLockManager()
Method Details
- heartbeatTimeoutMs
  
  public long heartbeatTimeoutMs()
- heartbeatIntervalMs
  
  public long heartbeatIntervalMs()
- acquireIntervalMs
  
  public long acquireIntervalMs()
- acquireTimeoutMs
  
  public long acquireTimeoutMs()
- heartbeatThreads
  
  public int heartbeatThreads()
- scheduler
  
  public ScheduledExecutorService scheduler()
  
  Returns the shared scheduler for lock heartbeats.
  Callers must not shut down this scheduler. It is shared across lock manager instances.
- initialize
  
  public void initialize(Map<String,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 Exception
  
  Specified by:
  
  close in interface AutoCloseable
  
  Throws:
  
  Exception