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/06/15 22:21:09 UTC
[4/4] incubator-beam git commit: This closes #466
This closes #466
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/021fa1e5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/021fa1e5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/021fa1e5
Branch: refs/heads/master
Commit: 021fa1e5f0e5ec7ca1fa77f978180f02ccf7b60a
Parents: 11eb9f6 bf476e1
Author: Kenneth Knowles <kl...@google.com>
Authored: Wed Jun 15 15:06:48 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Wed Jun 15 15:06:48 2016 -0700
----------------------------------------------------------------------
.../examples/common/DataflowExampleUtils.java | 11 +-
runners/spark/pom.xml | 6 +
.../translation/TransformTranslatorTest.java | 4 +-
.../java/org/apache/beam/sdk/io/PubsubIO.java | 1 -
.../main/java/org/apache/beam/sdk/io/Read.java | 44 -
.../java/org/apache/beam/sdk/io/TextIO.java | 1 -
.../beam/sdk/options/DirectPipelineOptions.java | 1 -
.../sdk/runners/DirectPipelineRegistrar.java | 55 -
.../beam/sdk/runners/DirectPipelineRunner.java | 1298 ------------------
.../apache/beam/sdk/transforms/DoFnTester.java | 62 +-
.../org/apache/beam/sdk/transforms/Flatten.java | 32 -
.../org/apache/beam/sdk/transforms/ParDo.java | 302 +---
.../org/apache/beam/sdk/transforms/View.java | 24 -
.../sdk/util/DirectModeExecutionContext.java | 130 --
.../apache/beam/sdk/util/DoFnRunnerBase.java | 1 -
.../java/org/apache/beam/sdk/PipelineTest.java | 4 +-
.../io/BoundedReadFromUnboundedSourceTest.java | 6 -
.../runners/DirectPipelineRegistrarTest.java | 71 -
.../sdk/runners/DirectPipelineRunnerTest.java | 222 ---
.../beam/sdk/runners/PipelineRunnerTest.java | 9 +-
.../apache/beam/sdk/transforms/CombineTest.java | 21 -
.../beam/sdk/transforms/GroupByKeyTest.java | 13 +-
.../apache/beam/sdk/transforms/ViewTest.java | 29 +-
.../sdk/util/GroupAlsoByWindowsProperties.java | 293 ++--
.../main/java/common/DataflowExampleUtils.java | 13 +-
testing/travis/test_wordcount.sh | 4 +-
26 files changed, 213 insertions(+), 2444 deletions(-)
----------------------------------------------------------------------