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 <[email protected]> Authored: Wed Jun 15 15:06:48 2016 -0700 Committer: Kenneth Knowles <[email protected]> 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(-) ----------------------------------------------------------------------
