You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/07/20 16:11:30 UTC
[3/3] incubator-beam git commit: This closes #323
This closes #323
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/02b2248a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/02b2248a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/02b2248a
Branch: refs/heads/gearpump-runner
Commit: 02b2248a5b3c8a2c064547d7380bebc97f849bf1
Parents: 64df4f2 9478f41
Author: Kenneth Knowles <kl...@google.com>
Authored: Wed Jul 20 09:07:48 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Wed Jul 20 09:07:48 2016 -0700
----------------------------------------------------------------------
runners/gearpump/README.md | 22 +
runners/gearpump/pom.xml | 296 +++++++++++
.../gearpump/GearpumpPipelineOptions.java | 67 +++
.../gearpump/GearpumpPipelineResult.java | 42 ++
.../gearpump/GearpumpPipelineRunner.java | 193 +++++++
.../GearpumpPipelineRunnerRegistrar.java | 63 +++
.../gearpump/GearpumpPipelineTranslator.java | 139 +++++
.../runners/gearpump/TestGearpumpRunner.java | 64 +++
.../gearpump/examples/StreamingWordCount.java | 105 ++++
.../gearpump/examples/UnboundedTextSource.java | 138 +++++
.../translators/CreateValuesTranslator.java | 49 ++
.../FlattenPCollectionTranslator.java | 47 ++
.../translators/GroupByKeyTranslator.java | 103 ++++
.../translators/ParDoBoundMultiTranslator.java | 154 ++++++
.../translators/ParDoBoundTranslator.java | 54 ++
.../translators/ReadBoundedTranslator.java | 44 ++
.../translators/ReadUnboundedTranslator.java | 46 ++
.../translators/TransformTranslator.java | 31 ++
.../translators/TranslationContext.java | 95 ++++
.../translators/functions/DoFnFunction.java | 88 ++++
.../translators/io/BoundedSourceWrapper.java | 44 ++
.../gearpump/translators/io/GearpumpSource.java | 100 ++++
.../translators/io/UnboundedSourceWrapper.java | 45 ++
.../gearpump/translators/io/ValuesSource.java | 164 ++++++
.../translators/utils/GearpumpDoFnRunner.java | 513 +++++++++++++++++++
.../translators/utils/NoOpSideInputReader.java | 48 ++
.../translators/utils/NoOpStepContext.java | 71 +++
runners/pom.xml | 11 +
.../apache/beam/sdk/testing/TestPipeline.java | 2 +
29 files changed, 2838 insertions(+)
----------------------------------------------------------------------