Package org.apache.flink.api.common.io
Interface InitializeOnMaster
-
- All Known Implementing Classes:
BinaryOutputFormat,FileOutputFormat,SerializedOutputFormat
@Public public interface InitializeOnMasterThis interface may be implemented byOutputFormats to have the master initialize them globally.For example, the
FileOutputFormatimplements this behavior for distributed file systems and creates/deletes target directories if necessary.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidinitializeGlobal(int parallelism)The method is invoked on the master (JobManager) before the distributed program execution starts.
-
-
-
Method Detail
-
initializeGlobal
void initializeGlobal(int parallelism) throws IOExceptionThe method is invoked on the master (JobManager) before the distributed program execution starts.- Parameters:
parallelism- The parallelism with which the format or functions will be run.- Throws:
IOException- The initialization may throw exceptions, which may cause the job to abort.
-
-