You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by hi...@apache.org on 2014/03/14 21:52:15 UTC
git commit: TEZ-930. Addendum patch. Provide additional aggregated
task stats at the vertex level. (hitesh)
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 <hi...@apache.org>
Authored: Fri Mar 14 13:51:51 2014 -0700
Committer: Hitesh Shah <hi...@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;
- }
-
-
-
}