tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hit...@apache.org
Subject git commit: TEZ-930. Addendum patch. Provide additional aggregated task stats at the vertex level. (hitesh)
Date Fri, 14 Mar 2014 20:52:15 GMT
Repository: incubator-tez
Updated Branches:
  refs/heads/master 6a2585764 -> 0d495f167


TEZ-930. Addendum patch. Provide additional aggregated task stats at the vertex level. (hitesh)


Project: http://git-wip-us.apache.org/repos/asf/incubator-tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tez/commit/0d495f16
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/0d495f16
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/0d495f16

Branch: refs/heads/master
Commit: 0d495f167f9deb8949dec3fd629e50749e439e8c
Parents: 6a25857
Author: Hitesh Shah <hitesh@apache.org>
Authored: Fri Mar 14 13:51:51 2014 -0700
Committer: Hitesh Shah <hitesh@apache.org>
Committed: Fri Mar 14 13:51:51 2014 -0700

----------------------------------------------------------------------
 .../apache/tez/dag/history/utils/DAGUtils.java  | 52 --------------------
 1 file changed, 52 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/0d495f16/tez-dag/src/main/java/org/apache/tez/dag/history/utils/DAGUtils.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/main/java/org/apache/tez/dag/history/utils/DAGUtils.java b/tez-dag/src/main/java/org/apache/tez/dag/history/utils/DAGUtils.java
index b8ea673..782fff1 100644
--- a/tez-dag/src/main/java/org/apache/tez/dag/history/utils/DAGUtils.java
+++ b/tez-dag/src/main/java/org/apache/tez/dag/history/utils/DAGUtils.java
@@ -18,14 +18,10 @@
 
 package org.apache.tez.dag.history.utils;
 
-import java.util.LinkedHashMap;
-import java.util.Map;
-
 import org.apache.tez.common.counters.CounterGroup;
 import org.apache.tez.common.counters.TezCounter;
 import org.apache.tez.common.counters.TezCounters;
 import org.apache.tez.dag.api.records.DAGProtos;
-import org.apache.tez.dag.app.dag.impl.VertexStats;
 import org.codehaus.jettison.json.JSONException;
 import org.codehaus.jettison.json.JSONObject;
 
@@ -153,52 +149,4 @@ public class DAGUtils {
     return jsonObject;
   }
 
-  public static Map<String,Object> convertVertexStatsToATSMap(
-      VertexStats vertexStats) {
-    Map<String,Object> vertexStatsMap = new LinkedHashMap<String, Object>();
-    if (vertexStats == null) {
-      return vertexStatsMap;
-    }
-
-    final String FIRST_TASK_START_TIME_KEY = "firstTaskStartTime";
-    final String FIRST_TASK_TO_START_KEY = "firstTaskToStart";
-    final String LAST_TASK_FINISH_TIME_KEY = "lastTaskFinishTime";
-    final String LAST_TASK_TO_FINISH_KEY = "lastTaskToFinish";
-
-    final String MIN_TASK_DURATION = "minTaskDuration";
-    final String MAX_TASK_DURATION = "maxTaskDuration";
-    final String AVG_TASK_DURATION = "avgTaskDuration";
-
-    final String SHORTEST_DURATION_TASK = "shortestDurationTask";
-    final String LONGEST_DURATION_TASK = "longestDurationTask";
-
-    vertexStatsMap.put(FIRST_TASK_START_TIME_KEY, vertexStats.getFirstTaskStartTime());
-    if (vertexStats.getFirstTaskToStart() != null) {
-      vertexStatsMap.put(FIRST_TASK_TO_START_KEY,
-          vertexStats.getFirstTaskToStart().toString());
-    }
-    vertexStatsMap.put(LAST_TASK_FINISH_TIME_KEY, vertexStats.getLastTaskFinishTime());
-    if (vertexStats.getLastTaskToFinish() != null) {
-      vertexStatsMap.put(LAST_TASK_TO_FINISH_KEY,
-          vertexStats.getLastTaskToFinish().toString());
-    }
-
-    vertexStatsMap.put(MIN_TASK_DURATION, vertexStats.getMinTaskDuration());
-    vertexStatsMap.put(MAX_TASK_DURATION, vertexStats.getMaxTaskDuration());
-    vertexStatsMap.put(AVG_TASK_DURATION, vertexStats.getAvgTaskDuration());
-
-    if (vertexStats.getShortestDurationTask() != null) {
-      vertexStatsMap.put(SHORTEST_DURATION_TASK,
-          vertexStats.getShortestDurationTask().toString());
-    }
-    if (vertexStats.getLongestDurationTask() != null) {
-      vertexStatsMap.put(LONGEST_DURATION_TASK,
-          vertexStats.getLongestDurationTask().toString());
-    }
-
-    return vertexStatsMap;
-  }
-
-
-
 }


Mime
View raw message