Repository: beam Updated Branches: refs/heads/master 26a2c47f4 -> f15b52fa3
This closes #1735 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f15b52fa Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f15b52fa Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f15b52fa Branch: refs/heads/master Commit: f15b52fa3d8549f9d1379e405733ebc2456075e5 Parents: 26a2c47 7b062d7 Author: Thomas Groh <[email protected]> Authored: Mon Jan 23 16:08:21 2017 -0800 Committer: Thomas Groh <[email protected]> Committed: Mon Jan 23 16:08:21 2017 -0800 ---------------------------------------------------------------------- .../translation/CreateValuesTranslator.java | 18 +++---- .../FlattenPCollectionTranslator.java | 28 ++++++++--- .../apex/translation/GroupByKeyTranslator.java | 2 +- .../translation/ParDoBoundMultiTranslator.java | 27 ++++++---- .../apex/translation/ParDoBoundTranslator.java | 4 +- .../apex/translation/TranslationContext.java | 27 +++++++--- .../apex/translation/WindowBoundTranslator.java | 4 +- .../direct/BoundedReadEvaluatorFactory.java | 10 ++-- .../beam/runners/direct/EvaluationContext.java | 2 +- .../direct/ExecutorServiceParallelExecutor.java | 4 +- .../runners/direct/FlattenEvaluatorFactory.java | 4 +- .../GroupAlsoByWindowEvaluatorFactory.java | 5 +- .../direct/GroupByKeyOnlyEvaluatorFactory.java | 10 +++- .../runners/direct/ParDoEvaluatorFactory.java | 17 ++++++- .../direct/StatefulParDoEvaluatorFactory.java | 12 +++-- .../direct/TestStreamEvaluatorFactory.java | 5 +- .../direct/UnboundedReadEvaluatorFactory.java | 13 +++-- .../runners/direct/ViewEvaluatorFactory.java | 8 +-- .../beam/runners/direct/WatermarkManager.java | 6 +-- .../runners/direct/WindowEvaluatorFactory.java | 3 +- .../runners/direct/DirectGraphVisitorTest.java | 16 +++--- .../beam/runners/direct/ParDoEvaluatorTest.java | 3 +- .../StatefulParDoEvaluatorFactoryTest.java | 4 +- .../FlinkBatchTransformTranslators.java | 40 +++++++++++---- .../FlinkBatchTranslationContext.java | 21 +++++--- .../FlinkStreamingTransformTranslators.java | 46 ++++++++++------- .../FlinkStreamingTranslationContext.java | 20 ++++++-- .../dataflow/DataflowPipelineTranslator.java | 53 +++++++++++++------- .../runners/dataflow/TransformTranslator.java | 9 +++- .../dataflow/DataflowPipelineJobTest.java | 29 +++++++---- .../spark/translation/EvaluationContext.java | 42 +++++++++------- .../spark/translation/TransformTranslator.java | 34 +++++++++---- .../streaming/StreamingTransformTranslator.java | 45 ++++++++++------- .../beam/sdk/transforms/AppliedPTransform.java | 11 ++-- 34 files changed, 385 insertions(+), 197 deletions(-) ----------------------------------------------------------------------
