TriggerLockFactory

All Superinterfaces:: AutoCloseable, Closeable, Serializable

All Known Implementing Classes:: JdbcLockFactory, ZkLockFactory

@Experimental public interface TriggerLockFactory extends Serializable, Closeable

Lock interface for handling locks for the Flink Table Maintenance jobs.

Nested Class Summary

Nested Classes

Modifier and Type

Interface

Description

static interface

TriggerLockFactory.Lock
Method Summary

Modifier and Type

Method

Description

TriggerLockFactory.Lock

createLock()

TriggerLockFactory.Lock

createRecoveryLock()

void

open()

Methods inherited from interface java.io.Closeable
close

Method Details
- open
  
  void open()
- createLock
  
  TriggerLockFactory.Lock createLock()
- createRecoveryLock
  
  TriggerLockFactory.Lock createRecoveryLock()