tez-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From yingdachen <...@git.apache.org>
Subject [GitHub] tez pull request #33: TEZ-3998: support constructing DAG with concurrent edg...
Date Thu, 08 Nov 2018 22:28:19 GMT
Github user yingdachen commented on a diff in the pull request:

    https://github.com/apache/tez/pull/33#discussion_r232084316
  
    --- Diff: tez-api/src/main/java/org/apache/tez/dag/api/EdgeProperty.java ---
    @@ -82,31 +82,50 @@
         PERSISTED_RELIABLE,
         /**
          * Data produced by the source task is available only while the source task
    -     * is running. This requires the destination task to run concurrently with 
    -     * the source task. This is not supported yet.
    +     * is running. This requires the destination task to run concurrently with
    +     * the source task. Development in progress.
          */
         @Unstable
         EPHEMERAL
       }
    -  
    +
       /**
    -   * Determines when the destination task is eligible to run, once the source  
    +   * Determines when the destination task is eligible to run, once the source
        * task is eligible to run.
        */
       public enum SchedulingType {
         /**
    -     * Destination task is eligible to run after one or more of its source tasks 
    +     * Destination task is eligible to run after one or more of its source tasks
          * have started or completed.
          */
         SEQUENTIAL,
         /**
          * Destination task must run concurrently with the source task.
    -     *  This is not supported yet.
    +     * Development in progress.
          */
         @Unstable
         CONCURRENT
       }
    -  
    +
    +  /**
    +   * Determines the relevant event(s) that will assist in scheduling downstream vertex
    +   * connected via a edge with CONCURRENT {@link SchedulingType}.
    +   */
    +  public enum ConcurrentEdgeTriggerType {
    +    /**
    +     * trigger downstream vertex tasks scheduling upon upstream vertex being configured
    --- End diff --
    
    done


---

Mime
View raw message