Package org.apache.iceberg.flink.maintenance.operator

package org.apache.iceberg.flink.maintenance.operator

Classes

Class	Description
DeleteFilesProcessor	Delete the files using the FileIO which implements SupportsBulkOperations.
ExpireSnapshotsProcessor	Calls the ExpireSnapshots to remove the old snapshots and emits the filenames which could be removed in the ExpireSnapshotsProcessor.DELETE_STREAM side output.
LockRemover	Manages locks and collect Metric for the Maintenance Tasks.
MonitorSource	Monitors an Iceberg table for changes
SingleThreadedIteratorSource<T>	Implementation of the Source V2 API which uses an iterator to read the elements, and uses a single thread to do so.
TableChange	Event describing changes in an Iceberg table
TableChange.Builder
TableMaintenanceMetrics
TriggerEvaluator
TriggerEvaluator.Builder
TriggerManager	TriggerManager starts the Maintenance Tasks by emitting Trigger messages which are calculated based on the incoming TableChange messages.