You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2018/01/22 17:41:39 UTC
[33/38] storm git commit: STORM-2153: Deprecate old user defined
metrics in favor of metrics v2
STORM-2153: Deprecate old user defined metrics in favor of metrics v2
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/8e2f7e7e
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/8e2f7e7e
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/8e2f7e7e
Branch: refs/heads/1.x-branch
Commit: 8e2f7e7ef621ff20d485bc0af9e6d18803777564
Parents: 6cb81fd
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Thu Jan 11 16:15:04 2018 -0500
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Thu Jan 11 16:15:04 2018 -0500
----------------------------------------------------------------------
storm-core/src/jvm/org/apache/storm/task/TopologyContext.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/8e2f7e7e/storm-core/src/jvm/org/apache/storm/task/TopologyContext.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/task/TopologyContext.java b/storm-core/src/jvm/org/apache/storm/task/TopologyContext.java
index 330fee1..2068439 100644
--- a/storm-core/src/jvm/org/apache/storm/task/TopologyContext.java
+++ b/storm-core/src/jvm/org/apache/storm/task/TopologyContext.java
@@ -313,6 +313,7 @@ public class TopologyContext extends WorkerTopologyContext implements IMetricsCo
* You must call this during `IBolt.prepare()` or `ISpout.open()`.
* @return The IMetric argument unchanged.
*/
+ @Deprecated
public <T extends IMetric> T registerMetric(String name, T metric, int timeBucketSizeInSecs) {
if((Boolean) _openOrPrepareWasCalled.deref()) {
throw new RuntimeException("TopologyContext.registerMetric can only be called from within overridden " +
@@ -359,6 +360,7 @@ public class TopologyContext extends WorkerTopologyContext implements IMetricsCo
* cause the same metric name can register twice.
* So we just return the first metric we meet.
*/
+ @Deprecated
public IMetric getRegisteredMetricByName(String name) {
IMetric metric = null;
@@ -379,12 +381,14 @@ public class TopologyContext extends WorkerTopologyContext implements IMetricsCo
/*
* Convenience method for registering ReducedMetric.
*/
+ @Deprecated
public ReducedMetric registerMetric(String name, IReducer reducer, int timeBucketSizeInSecs) {
return registerMetric(name, new ReducedMetric(reducer), timeBucketSizeInSecs);
}
/*
* Convenience method for registering CombinedMetric.
*/
+ @Deprecated
public CombinedMetric registerMetric(String name, ICombiner combiner, int timeBucketSizeInSecs) {
return registerMetric(name, new CombinedMetric(combiner), timeBucketSizeInSecs);
}