org.apache.flink.api.common.io

Interface FinalizeOnMaster

All Known Implementing Classes:

HadoopOutputFormat, HadoopOutputFormat, HadoopOutputFormatBase, HadoopOutputFormatBase

@Public
public interface FinalizeOnMaster

This interface may be implemented by OutputFormats to have the master finalize them globally.

Method Summary

Modifier and Type	Method and Description
void	finalizeGlobal(int parallelism) The method is invoked on the master (JobManager) after all (parallel) instances of an OutputFormat finished.

Method Detail

finalizeGlobal

void finalizeGlobal(int parallelism)
             throws IOException

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.