Class LockManagers.BaseLockManager

    • 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