Package org.apache.iceberg.flink.maintenance.operator
package org.apache.iceberg.flink.maintenance.operator
-
ClassDescriptionJDBC table backed implementation of the
TriggerLockFactory
.Manages locks and collectMetric
for the Maintenance Tasks.Implementation of the Source V2 API which uses an iterator to read the elements, and uses a single thread to do so.The result of a single Maintenance Task.Lock interface for handling locks for the Flink Table Maintenance jobs.