This closes #3812
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ef70031b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ef70031b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ef70031b Branch: refs/heads/jstorm-runner Commit: ef70031b7b0e48ae5750725f8ff6a9cd71f37431 Parents: d2b2851 fec423e Author: Pei He <[email protected]> Authored: Fri Sep 8 14:43:37 2017 +0800 Committer: Pei He <[email protected]> Committed: Fri Sep 8 14:43:37 2017 +0800 ---------------------------------------------------------------------- runners/jstorm/pom.xml | 1 - .../beam/runners/jstorm/JStormRunnerResult.java | 38 +++++++++++- .../beam/runners/jstorm/TestJStormRunner.java | 19 +----- .../jstorm/translation/JStormMetricResults.java | 63 +++++++++++++++++--- .../jstorm/translation/MetricsReporter.java | 56 +++++++++++++++++ .../translation/UnboundedSourceSpout.java | 30 +++++++--- 6 files changed, 170 insertions(+), 37 deletions(-) ----------------------------------------------------------------------
