STORM-2153: Add transferred metric
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/47be75c8 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/47be75c8 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/47be75c8 Branch: refs/heads/1.x-branch Commit: 47be75c8d2fc5f9c7901595fecb385393f9fab8b Parents: 5ce45b7 Author: P. Taylor Goetz <[email protected]> Authored: Fri Dec 15 12:48:08 2017 -0500 Committer: P. Taylor Goetz <[email protected]> Committed: Fri Dec 15 12:48:08 2017 -0500 ---------------------------------------------------------------------- storm-core/src/clj/org/apache/storm/daemon/task.clj | 4 ++-- storm-core/src/clj/org/apache/storm/stats.clj | 3 ++- 2 files changed, 4 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/47be75c8/storm-core/src/clj/org/apache/storm/daemon/task.clj ---------------------------------------------------------------------- diff --git a/storm-core/src/clj/org/apache/storm/daemon/task.clj b/storm-core/src/clj/org/apache/storm/daemon/task.clj index 8eb432e..7132fc1 100644 --- a/storm-core/src/clj/org/apache/storm/daemon/task.clj +++ b/storm-core/src/clj/org/apache/storm/daemon/task.clj @@ -145,7 +145,7 @@ (when (emit-sampler) (stats/emitted-tuple! executor-stats (StormMetricRegistry/counter "emitted" worker-context component-id (pr-str (:executor-id executor-data)) stream) stream) (if out-task-id - (stats/transferred-tuples! executor-stats stream 1))) + (stats/transferred-tuples! executor-stats (StormMetricRegistry/counter "transferred" worker-context component-id (pr-str (:executor-id executor-data)) stream) stream 1))) (if out-task-id [out-task-id]) )) ([^String stream ^List values] @@ -164,7 +164,7 @@ (apply-hooks user-context .emit (EmitInfo. values stream task-id out-tasks)) (when (emit-sampler) (stats/emitted-tuple! executor-stats (StormMetricRegistry/counter "emitted" worker-context component-id (pr-str (:executor-id executor-data)) stream) stream) - (stats/transferred-tuples! executor-stats stream (count out-tasks))) + (stats/transferred-tuples! executor-stats (StormMetricRegistry/counter "transferred" worker-context component-id (pr-str (:executor-id executor-data)) stream) stream (count out-tasks))) out-tasks))) )) http://git-wip-us.apache.org/repos/asf/storm/blob/47be75c8/storm-core/src/clj/org/apache/storm/stats.clj ---------------------------------------------------------------------- diff --git a/storm-core/src/clj/org/apache/storm/stats.clj b/storm-core/src/clj/org/apache/storm/stats.clj index 41aaf04..85c7bbe 100644 --- a/storm-core/src/clj/org/apache/storm/stats.clj +++ b/storm-core/src/clj/org/apache/storm/stats.clj @@ -125,8 +125,9 @@ (.inc emitted-counter rate))) (defn transferred-tuples! - [stats stream amt] + [stats ^Counter transferred-counter stream amt] (let [^MultiCountStatAndMetric transferred (stats-transferred stats)] + (.inc transferred-counter amt) (.incBy transferred ^Object stream ^long (* (stats-rate stats) amt)))) (defn bolt-execute-tuple!
