Package org.apache.nemo.runtime.master.scheduler

Class BatchSchedulerUtils

  • public final class BatchSchedulerUtils
extends java.lang.Object
    Utlity methods regarding schedulers.

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static void onRunTimePassMessage​(PlanStateManager planStateManager, PlanRewriter planRewriter, java.lang.String taskId, java.lang.Object data)
      Process the RuntimePassMessage.

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Method Detail

      • onRunTimePassMessage

        public static void onRunTimePassMessage​(PlanStateManager planStateManager,
                                        PlanRewriter planRewriter,
                                        java.lang.String taskId,
                                        java.lang.Object data)
        Process the RuntimePassMessage.
        Parameters:
        planStateManager - to get the edges for the optimization.
        planRewriter - for rewriting the plan later on.
        taskId - that generated the message.
        data - of the message.