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

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

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.
DVPosition	A deletion vector position emitted by EqualityConvertPKIndex when resolving an equality delete.
DVWriteResult	Result from the EqualityConvertDVWriter containing new and rewritten DV files written by a single resolver task.
EqualityConvertCommitter	Commits data files and DVs to the target branch.
EqualityConvertDVWriter	Keyed parallel resolver that buffers DVPositions per data-file path, then writes Puffin DV files directly via BaseDVFileWriter.
EqualityConvertPKIndex	Parallel operator that maintains a shard of the primary key index.
EqualityConvertPlan	Result of equality convert planning.
EqualityConvertPlanner	Planner for the equality delete conversion pipeline.
EqualityConvertReader	Parallel reader that processes ReadCommands from the planner and emits IndexCommands.
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.
IndexCommand	Command from the EqualityConvertPlanner to the EqualityConvertPKIndex.
IndexCommand.Type
ListFileSystemFiles	Recursively lists the files in the `location` directory.
ListMetadataFiles	Lists the metadata files referenced by the table.
LockFactoryBuilder
LockRegisterEvent	Event sent from TriggerManagerOperator to TriggerManagerCoordinator to register a lock release handler.
LockReleaseEvent	Event sent from LockRemoverOperator to LockRemoverCoordinator to notify that a lock has been released.
LockRemover	Manages locks and collect Metric for the Maintenance Tasks.
LockRemoverOperatorFactory
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.
ReadCommand	Envelope from the EqualityConvertPlanner to the EqualityConvertReader, wrapping an Iceberg ContentScanTask plus the metadata the reader needs to process it.
SerializedEqualityValues	Serialized primary key used as a Flink keyed state key.
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.
TriggerManagerOperatorFactory