Package org.apache.iceberg.flink.maintenance.operator
-
Interface Summary Interface Description TriggerLockFactory Lock interface for handling locks for the Flink Table Maintenance jobs.TriggerLockFactory.Lock -
Class Summary Class Description JdbcLockFactory JDBC table backed implementation of theTriggerLockFactory
.LockRemover Manages locks and collectMetric
for the Maintenance Tasks.SingleThreadedIteratorSource<T> Implementation of the Source V2 API which uses an iterator to read the elements, and uses a single thread to do so.TableMaintenanceMetrics TaskResult The result of a single Maintenance Task.