beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tg...@apache.org
Subject [1/3] incubator-beam git commit: This closes #1484
Date Thu, 01 Dec 2016 22:34:36 GMT
Repository: incubator-beam
Updated Branches:
  refs/heads/master 24fab9f53 -> 63491bf21


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/master
Commit: 63491bf211d8b2f23f6b7db1375a733c4332b850
Parents: 24fab9f 7c5c791
Author: Thomas Groh <tgroh@google.com>
Authored: Thu Dec 1 14:34:21 2016 -0800
Committer: Thomas Groh <tgroh@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(-)
----------------------------------------------------------------------



Mime
View raw message