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 <hepei...@alibaba-inc.com> Authored: Sat Apr 22 15:12:45 2017 +0800 Committer: Pei He <hepei...@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(+) ----------------------------------------------------------------------
