Package org.apache.flink.connector.file.sink.compactor.operator
-
Class Summary Class Description CompactCoordinator Coordinator that coordinates file compaction for theFileSink.CompactCoordinatorFactory Factory forCompactCoordinator.CompactCoordinatorStateHandler Handler that processes the state ofCompactCoordinatorwhen compaction is disabled.CompactCoordinatorStateHandlerFactory Factory forCompactCoordinatorStateHandler.CompactorOperator An operator that perform compaction for theFileSink.CompactorOperatorFactory Factory forCompactorOperator.CompactorOperatorStateHandler Handler that processes the state ofCompactorOperatorwhen compaction is disabled.CompactorOperatorStateHandlerFactory Factory forCompactorOperatorStateHandler.CompactorRequest Request of file compacting forFileSink.CompactorRequestSerializer Versioned serializer forCompactorRequest.CompactorRequestTypeInfo Type information ofCompactorRequest.CompactService The asynchronous file compaction service.