This closes #3792
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7a28bf1a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7a28bf1a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7a28bf1a Branch: refs/heads/jstorm-runner Commit: 7a28bf1af44bb498b5702031e64edd3d918245a6 Parents: 9148899 6f40506 Author: Pei He <p...@apache.org> Authored: Mon Sep 4 12:58:50 2017 +0800 Committer: Pei He <p...@apache.org> Committed: Mon Sep 4 12:58:50 2017 +0800 ---------------------------------------------------------------------- .../beam/runners/jstorm/JStormRunnerResult.java | 53 +++++++++- .../beam/runners/jstorm/TestJStormRunner.java | 100 +++++++++++------- .../jstorm/translation/CommonInstance.java | 5 + .../jstorm/translation/DoFnExecutor.java | 5 +- .../jstorm/translation/ExecutorsBolt.java | 35 ++++++- .../translation/GroupByWindowExecutor.java | 2 +- .../jstorm/translation/JStormMetricResults.java | 105 +++++++++++++++++++ .../jstorm/translation/MetricsReporter.java | 36 ++++++- .../translation/UnboundedSourceSpout.java | 38 ++++--- 9 files changed, 308 insertions(+), 71 deletions(-) ----------------------------------------------------------------------
