You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by gu...@apache.org on 2013/08/30 05:54:18 UTC
svn commit: r1518889 -
/hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java
Author: gunther
Date: Fri Aug 30 03:54:17 2013
New Revision: 1518889
URL: http://svn.apache.org/r1518889
Log:
HIVE-5183: Tez EdgeProperty class has changed (Gunther Hagleitner)
Modified:
hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java
Modified: hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java
URL: http://svn.apache.org/viewvc/hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java?rev=1518889&r1=1518888&r2=1518889&view=diff
==============================================================================
--- hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java (original)
+++ hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java Fri Aug 30 03:54:17 2013
@@ -60,8 +60,9 @@ import org.apache.hadoop.yarn.util.Conve
import org.apache.hadoop.yarn.util.Records;
import org.apache.tez.dag.api.Edge;
import org.apache.tez.dag.api.EdgeProperty;
-import org.apache.tez.dag.api.EdgeProperty.ConnectionPattern;
-import org.apache.tez.dag.api.EdgeProperty.SourceType;
+import org.apache.tez.dag.api.EdgeProperty.DataMovementType;
+import org.apache.tez.dag.api.EdgeProperty.DataSourceType;
+import org.apache.tez.dag.api.EdgeProperty.SchedulingType;
import org.apache.tez.dag.api.InputDescriptor;
import org.apache.tez.dag.api.OutputDescriptor;
import org.apache.tez.dag.api.ProcessorDescriptor;
@@ -155,7 +156,9 @@ public class DagUtils {
// all edges are of the same type right now
EdgeProperty edgeProperty =
- new EdgeProperty(ConnectionPattern.BIPARTITE, SourceType.STABLE,
+ new EdgeProperty(DataMovementType.SCATTER_GATHER,
+ DataSourceType.PERSISTED,
+ SchedulingType.SEQUENTIAL,
new OutputDescriptor(OnFileSortedOutput.class.getName()),
new InputDescriptor(ShuffledMergedInput.class.getName()));
return new Edge(v, w, edgeProperty);