You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by pe...@apache.org on 2017/04/22 07:14:04 UTC
[3/3] beam git commit: This closes #2457
This closes #2457
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f6a89b0f
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f6a89b0f
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f6a89b0f
Branch: refs/heads/jstorm-runner
Commit: f6a89b0fc2428d2f85e087525a6ddb5361eed4cb
Parents: a8edbb8 15ebaf0
Author: Pei He <he...@alibaba-inc.com>
Authored: Sat Apr 22 15:12:45 2017 +0800
Committer: Pei He <he...@alibaba-inc.com>
Committed: Sat Apr 22 15:12:45 2017 +0800
----------------------------------------------------------------------
runners/jstorm/pom.xml | 194 +++++++++++++++++++
.../runners/jstorm/JStormPipelineOptions.java | 26 +++
.../beam/runners/jstorm/JStormRunner.java | 33 ++++
.../runners/jstorm/JStormRunnerRegistrar.java | 55 ++++++
.../beam/runners/jstorm/JStormRunnerResult.java | 63 ++++++
.../beam/runners/jstorm/package-info.java | 22 +++
.../jstorm/JStormRunnerRegistrarTest.java | 49 +++++
runners/pom.xml | 1 +
8 files changed, 443 insertions(+)
----------------------------------------------------------------------