You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by jk...@apache.org on 2018/06/21 04:41:43 UTC

[beam] 01/01: Merge pull request #5703: Introduces PipelineValidator that checks the well-formedness of a pipeline

This is an automated email from the ASF dual-hosted git repository.

jkff pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit db1057c37e0249029bdd6302567e1e2ce124e269
Merge: 9d5cbc4 e0c377a
Author: Eugene Kirpichov <ek...@gmail.com>
AuthorDate: Wed Jun 20 21:41:37 2018 -0700

    Merge pull request #5703: Introduces PipelineValidator that checks the well-formedness of a pipeline
    
    Introduces PipelineValidator that checks the well-formedness of a pipeline

 .../core/construction/PipelineTranslation.java     |   7 +-
 .../core/construction/graph/ExecutableStage.java   |   6 +-
 .../core/construction/graph/FusedPipeline.java     |   9 +-
 .../construction/graph/GreedyPipelineFuser.java    |   2 +
 .../construction/graph/OutputDeduplicator.java     |   9 +-
 .../core/construction/graph/PipelineValidator.java | 287 +++++++++++++++++++++
 .../construction/graph/ExecutableStageTest.java    |   4 +-
 .../graph/GreedyPipelineFuserTest.java             | 264 +++++++++++--------
 .../graph/ImmutableExecutableStageTest.java        |   2 +-
 .../runners/direct/portable/ReferenceRunner.java   |  16 +-
 .../jobsubmission/InMemoryJobService.java          |   6 +
 ...gleEnvironmentInstanceJobBundleFactoryTest.java |   2 +-
 .../beam/runners/reference/ReferenceRunner.java    |  35 ---
 13 files changed, 488 insertions(+), 161 deletions(-)