beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From p..@apache.org
Subject [4/4] beam git commit: This closes #3792
Date Mon, 04 Sep 2017 04:59:28 GMT
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 <pei@apache.org>
Authored: Mon Sep 4 12:58:50 2017 +0800
Committer: Pei He <pei@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(-)
----------------------------------------------------------------------



Mime
View raw message