Interface FinalizeOnMaster


  • @Public
    public interface FinalizeOnMaster
    This interface may be implemented by OutputFormats to have the master finalize them globally.
    • Method Detail

      • finalizeGlobal

        @Deprecated
        default void finalizeGlobal​(int parallelism)
                             throws IOException
        Deprecated.
        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.
      • finalizeGlobal

        default void finalizeGlobal​(FinalizeOnMaster.FinalizationContext context)
                             throws IOException
        The method is invoked on the master (JobManager) after all (parallel) instances of an OutputFormat finished.
        Parameters:
        context - The context to get finalization infos.
        Throws:
        IOException - The finalization may throw exceptions, which may cause the job to abort.