Merge branch 'agresch_workermetricprocessor' of https://github.com/agresch/storm into STORM-2939
STORM-2939: add WorkerMetricsProcessor interface This closes #2554 Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/a323987b Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/a323987b Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/a323987b Branch: refs/heads/master Commit: a323987bb7325eb9756ea6371b72dbe1ce409cc0 Parents: c8fab20 23d704a Author: Robert Evans <ev...@yahoo-inc.com> Authored: Tue Feb 13 14:10:58 2018 -0600 Committer: Robert Evans <ev...@yahoo-inc.com> Committed: Tue Feb 13 14:10:58 2018 -0600 ---------------------------------------------------------------------- conf/defaults.yaml | 1 + docs/storm-metricstore.md | 3 ++ .../java/org/apache/storm/DaemonConfig.java | 10 ++++- .../storm/daemon/supervisor/Container.java | 10 +++-- .../daemon/supervisor/ReadClusterState.java | 13 ++++++- .../apache/storm/daemon/supervisor/Slot.java | 13 +++++-- .../storm/metricstore/MetricStoreConfig.java | 24 ++++++++++-- .../metricstore/NimbusMetricProcessor.java | 41 ++++++++++++++++++++ .../metricstore/WorkerMetricsProcessor.java | 40 +++++++++++++++++++ .../storm/daemon/supervisor/SlotTest.java | 14 +++---- 10 files changed, 148 insertions(+), 21 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/a323987b/storm-server/src/main/java/org/apache/storm/DaemonConfig.java ----------------------------------------------------------------------