org.apache.flink.api.common.io

Interface InitializeOnMaster

All Known Implementing Classes:

AvroOutputFormat, BinaryOutputFormat, CsvOutputFormat, FileOutputFormat, ScalaCsvOutputFormat, SerializedOutputFormat, TextOutputFormat, TypeSerializerOutputFormat

@Public
public interface InitializeOnMaster

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

For example, the FileOutputFormat implements this behavior for distributed file systems and creates/deletes target directories if necessary.

Method Summary

Modifier and Type	Method and Description
void	initializeGlobal(int parallelism) The method is invoked on the master (JobManager) before the distributed program execution starts.

Method Detail

initializeGlobal

void initializeGlobal(int parallelism)
               throws IOException

The 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.