This closes #2006
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2ca3bf66 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2ca3bf66 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2ca3bf66 Branch: refs/heads/master Commit: 2ca3bf6690b4e9613bfcd4d3420c8da412a0ec7a Parents: 41b2409 77a1afb Author: Thomas Groh <tg...@google.com> Authored: Thu Feb 16 18:57:58 2017 -0800 Committer: Thomas Groh <tg...@google.com> Committed: Thu Feb 16 18:57:58 2017 -0800 ---------------------------------------------------------------------- .../translation/ParDoBoundMultiTranslator.java | 5 ++ .../apex/translation/ParDoBoundTranslator.java | 5 ++ .../beam/runners/direct/DirectRunner.java | 88 ++++++++++++-------- .../beam/runners/direct/EvaluationContext.java | 3 +- .../direct/TestStreamEvaluatorFactory.java | 3 +- .../direct/WriteWithShardingFactory.java | 24 +++--- .../beam/runners/direct/DirectRunnerTest.java | 3 +- .../direct/KeyedPValueTrackingVisitorTest.java | 23 ++++- .../StatefulParDoEvaluatorFactoryTest.java | 57 ++++++++----- .../direct/TestStreamEvaluatorFactoryTest.java | 20 ++--- .../direct/ViewEvaluatorFactoryTest.java | 4 +- .../FlinkBatchTransformTranslators.java | 12 +++ .../FlinkStreamingTransformTranslators.java | 12 +++ .../dataflow/DataflowPipelineTranslator.java | 7 ++ .../spark/translation/TransformTranslator.java | 3 + .../spark/translation/TranslationUtils.java | 9 ++ .../streaming/StreamingTransformTranslator.java | 3 + .../beam/sdk/runners/TransformHierarchy.java | 28 ++++++- .../org/apache/beam/sdk/testing/TestStream.java | 10 +-- .../org/apache/beam/sdk/transforms/ParDo.java | 9 +- .../apache/beam/sdk/testing/TestStreamTest.java | 17 ---- .../apache/beam/sdk/transforms/ParDoTest.java | 30 ------- 22 files changed, 225 insertions(+), 150 deletions(-) ----------------------------------------------------------------------
