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/12/06 16:40:58 UTC
[08/50] [abbrv] incubator-beam git commit: This closes #1484
This closes #1484
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/63491bf2
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/63491bf2
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/63491bf2
Branch: refs/heads/gearpump-runner
Commit: 63491bf211d8b2f23f6b7db1375a733c4332b850
Parents: 24fab9f 7c5c791
Author: Thomas Groh <tg...@google.com>
Authored: Thu Dec 1 14:34:21 2016 -0800
Committer: Thomas Groh <tg...@google.com>
Committed: Thu Dec 1 14:34:21 2016 -0800
----------------------------------------------------------------------
.../translation/ApexPipelineTranslator.java | 12 +-
.../apex/translation/TranslationContext.java | 6 +-
.../direct/ConsumerTrackingPipelineVisitor.java | 12 +-
.../runners/direct/DisplayDataValidator.java | 6 +-
.../direct/KeyedPValueTrackingVisitor.java | 10 +-
.../apache/beam/runners/flink/FlinkRunner.java | 12 +-
.../FlinkBatchPipelineTranslator.java | 14 +-
.../FlinkStreamingPipelineTranslator.java | 16 +-
.../PipelineTranslationOptimizer.java | 10 +-
.../dataflow/DataflowPipelineTranslator.java | 8 +-
.../beam/runners/dataflow/DataflowRunner.java | 10 +-
.../runners/dataflow/DataflowRunnerTest.java | 4 +-
.../dataflow/RecordingPipelineVisitor.java | 6 +-
.../apache/beam/runners/spark/SparkRunner.java | 21 +-
.../beam/sdk/AggregatorPipelineExtractor.java | 6 +-
.../main/java/org/apache/beam/sdk/Pipeline.java | 17 +-
.../beam/sdk/runners/TransformHierarchy.java | 244 +++++++++++++++-
.../beam/sdk/runners/TransformTreeNode.java | 282 -------------------
.../sdk/AggregatorPipelineExtractorTest.java | 20 +-
.../sdk/runners/TransformHierarchyTest.java | 26 +-
.../beam/sdk/runners/TransformTreeTest.java | 8 +-
.../display/DisplayDataEvaluator.java | 8 +-
22 files changed, 344 insertions(+), 414 deletions(-)
----------------------------------------------------------------------