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

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

Classes

Class	Description
DataFileRewriteCommitter	Commits the rewrite changes using RewriteDataFilesCommitManager.
DataFileRewritePlanner	Plans the rewrite groups using the BinPackRewriteFilePlanner.
DataFileRewritePlanner.PlannedGroup
DataFileRewriteRunner	Executes a rewrite for a single DataFileRewritePlanner.PlannedGroup.
DataFileRewriteRunner.ExecutedGroup
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.
FileNameReader	A specialized reader implementation that extracts file names from Iceberg table rows.
FileUriKeySelector	A key selector implementation that extracts a normalized file path from a file URI string.
ListFileSystemFiles	Recursively lists the files in the `location` directory.
ListMetadataFiles	Lists the metadata files referenced by the table.
LockFactoryBuilder
LockRemover	Manages locks and collect Metric for the Maintenance Tasks.
MetadataTablePlanner	Plans the splits to read a metadata table content.
MetadataTablePlanner.SplitInfo
MonitorSource	Monitors an Iceberg table for changes
OrphanFilesDetector	A specialized co-process function that performs an anti-join between two streams of file URIs.
SingleThreadedIteratorSource<T>	Implementation of the Source V2 API which uses an iterator to read the elements, and uses a single thread to do so.
SkipOnError	Skip file deletion processing when an error is encountered.
TableChange	Event describing changes in an Iceberg table
TableChange.Builder
TableMaintenanceMetrics
TaskResultAggregator	Aggregates results of the operators for a given maintenance task.
TriggerEvaluator
TriggerEvaluator.Builder
TriggerManager	TriggerManager starts the Maintenance Tasks by emitting Trigger messages which are calculated based on the incoming TableChange messages.