svn commit: r1514100 - /hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java

[gu...@apache.org]

Author: gunther
Date: Wed Aug 14 23:45:46 2013
New Revision: 1514100

URL: http://svn.apache.org/r1514100
Log:
HIVE-5097: Update DagUtils to reflect changes in Tez API (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=1514100&r1=1514099&r2=1514100&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 Wed Aug 14 23:45:46 2013
@@ -156,8 +156,8 @@ public class DagUtils {
     // all edges are of the same type right now
     EdgeProperty edgeProperty =
         new EdgeProperty(ConnectionPattern.BIPARTITE, SourceType.STABLE,
-            new OutputDescriptor(OnFileSortedOutput.class.getName(), null),
-            new InputDescriptor(ShuffledMergedInput.class.getName(), null));
+            new OutputDescriptor(OnFileSortedOutput.class.getName()),
+            new InputDescriptor(ShuffledMergedInput.class.getName()));
     return new Edge(v, w, edgeProperty);
   }
 
@@ -204,8 +204,8 @@ public class DagUtils {
     Vertex map = null;
     if (inputSplitInfo.getNumTasks() != 0) {
       map = new Vertex("Map "+seqNo,
-          new ProcessorDescriptor(MapProcessor.class.getName(),
-              MRHelpers.createUserPayloadFromConf(conf)),
+          new ProcessorDescriptor(MapProcessor.class.getName()).
+               setUserPayload(MRHelpers.createUserPayloadFromConf(conf)),
           inputSplitInfo.getNumTasks(), MRHelpers.getMapResource(conf));
       Map<String, String> environment = new HashMap<String, String>();
       MRHelpers.updateEnvironmentForMRTasks(conf, environment, true);
@@ -277,9 +277,9 @@ public class DagUtils {
 
     // create the vertex
     Vertex reducer = new Vertex("Reducer "+seqNo,
-        new ProcessorDescriptor(ReduceProcessor.class.getName(),
-            MRHelpers.createUserPayloadFromConf(conf)),
-            reduceWork.getNumReduceTasks(), MRHelpers.getReduceResource(conf));
+        new ProcessorDescriptor(ReduceProcessor.class.getName()).
+             setUserPayload(MRHelpers.createUserPayloadFromConf(conf)),
+        reduceWork.getNumReduceTasks(), MRHelpers.getReduceResource(conf));
 
     Map<String, String> environment = new HashMap<String, String>();