You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2014/07/01 22:40:34 UTC

[03/24] git commit: add AssignableShellMetric.java to rpc

add AssignableShellMetric.java to rpc


Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/5448955d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/5448955d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/5448955d

Branch: refs/heads/master
Commit: 5448955dba2ffee133b1bd8b4d144611fcdcc751
Parents: ecb39a7
Author: JuDasheng <ju...@meituan.com>
Authored: Thu Mar 6 17:03:09 2014 +0800
Committer: JuDasheng <ju...@meituan.com>
Committed: Thu Mar 6 17:03:09 2014 +0800

----------------------------------------------------------------------
 .../storm/metric/api/rpc/AssignableShellMetric.java    | 13 +++++++++++++
 1 file changed, 13 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/5448955d/storm-core/src/jvm/backtype/storm/metric/api/rpc/AssignableShellMetric.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/metric/api/rpc/AssignableShellMetric.java b/storm-core/src/jvm/backtype/storm/metric/api/rpc/AssignableShellMetric.java
new file mode 100644
index 0000000..e0722b8
--- /dev/null
+++ b/storm-core/src/jvm/backtype/storm/metric/api/rpc/AssignableShellMetric.java
@@ -0,0 +1,13 @@
+package backtype.storm.metric.api.rpc;
+
+import backtype.storm.metric.api.AssignableMetric;
+
+public class AssignableShellMetric extends AssignableMetric implements IShellMetric {
+    public AssignableShellMetric(Object value) {
+        super(value);
+    }
+
+    public void updateMetricFromRPC(Object value) {
+        setValue(value);
+    }
+}