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 Abstract Methods Modifier and Type Method Description voidfinalizeGlobal(FinalizeOnMaster.FinalizationContext context)The method is invoked on the master (JobManager) after all (parallel) instances of an OutputFormat finished.
-
-
-
Method Detail
-
finalizeGlobal
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.
-
-