Interface JobVertex.FinalizeOnMasterContext

  • Enclosing class:
    JobVertex

    public static interface JobVertex.FinalizeOnMasterContext
    The context exposes some runtime infos for finalization.
    • Method Detail

      • getClassLoader

        ClassLoader getClassLoader()
        The class loader for user defined code.
      • getExecutionParallelism

        int getExecutionParallelism()
        The actual parallelism this vertex will be run with. In contrast, the JobVertex.getParallelism() is the original parallelism set when creating the JobGraph and might be updated e.g. by the AdaptiveScheduler.
      • getFinishedAttempt

        int getFinishedAttempt​(int subtaskIndex)
        Get the finished attempt number of subtask.
        Parameters:
        subtaskIndex - the subtask index.
        Returns:
        the finished attempt.
        Throws:
        IllegalArgumentException - Thrown, if subtaskIndex is invalid.