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