Interface InitializeOnMaster

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