@Public public interface InitializeOnMaster
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.
|Modifier and Type||Method and Description|
The method is invoked on the master (JobManager) before the distributed program execution starts.
void initializeGlobal(int parallelism) throws IOException
parallelism- The parallelism with which the format or functions will be run.
IOException- The initialization may throw exceptions, which may cause the job to abort.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.