Package org.apache.flink.connector.file.table.stream.compact

Interface Summary

Interface	Description
CompactContext	Context for CompactReader and CompactWriter.
CompactMessages.CoordinatorInput	The input of compact coordinator.
CompactMessages.CoordinatorOutput	The output of compact coordinator.
CompactReader<T>	Reader for compaction.
CompactReader.Factory<T>	Factory to create CompactReader.
CompactWriter<T>	Writer for compaction.
CompactWriter.Factory<T>	Factory to create CompactWriter.

Class Summary

Class	Description
CompactBucketWriter<T>	The CompactWriter to delegate BucketWriter.
CompactBulkReader<T>	The CompactReader to delegate CompactBulkReader.
CompactContext.CompactContextImpl	Implementation of CompactContext.
CompactCoordinator	This is the single (non-parallel) monitoring task which coordinate input files to compaction units. - Receives in-flight input files inside checkpoint. - Receives all upstream end input messages after the checkpoint completes successfully, starts coordination.
CompactFileWriter<T>	Writer for emitting CompactMessages.InputFile and CompactMessages.EndCheckpoint to downstream.
CompactMessages	Util class for all compaction messages.
CompactMessages.CompactionUnit	The unit of a single compaction.
CompactMessages.CompactOutput	The output of BatchCompactOperator.
CompactMessages.EndCheckpoint	A flag to end checkpoint, coordinator can start coordinating one checkpoint.
CompactMessages.EndCompaction	A flag to end compaction.
CompactMessages.InputFile	A partitioned input file.
CompactOperator<T>	Receives compaction units to do compaction.
FileInputFormatCompactReader<T>	The CompactReader to delegate FileInputFormat.