Package org.apache.flink.api.common.io
Interface FinalizeOnMaster
-
@Public public interface FinalizeOnMasterThis interface may be implemented byOutputFormats to have the master finalize them globally.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static interfaceFinalizeOnMaster.FinalizationContextA context that provides parallelism and finished attempts infos.
-
Method Summary
All Methods Instance Methods Default Methods Deprecated Methods Modifier and Type Method Description default voidfinalizeGlobal(int parallelism)Deprecated.UsefinalizeGlobal(FinalizationContext)instead.default voidfinalizeGlobal(FinalizeOnMaster.FinalizationContext context)The method is invoked on the master (JobManager) after all (parallel) instances of an OutputFormat finished.
-
-
-
Method Detail
-
finalizeGlobal
@Deprecated default void finalizeGlobal(int parallelism) throws IOException
Deprecated.UsefinalizeGlobal(FinalizationContext)instead.The method is invoked on the master (JobManager) after all (parallel) instances of an OutputFormat finished.- Parameters:
parallelism- The parallelism with which the format or functions was run.- Throws:
IOException- The finalization may throw exceptions, which may cause the job to abort.
-
finalizeGlobal
default void finalizeGlobal(FinalizeOnMaster.FinalizationContext context) throws IOException
The method is invoked on the master (JobManager) after all (parallel) instances of an OutputFormat finished.- Parameters:
context- The context to get finalization infos.- Throws:
IOException- The finalization may throw exceptions, which may cause the job to abort.
-
-