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 <[email protected]> Authored: Thu Jan 11 16:15:04 2018 -0500 Committer: P. Taylor Goetz <[email protected]> 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); }
