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

Posted to commits@beam.apache.org by mx...@apache.org on 2019/05/20 16:41:43 UTC

[beam] 01/01: Merge pull request #8592: [BEAM-7305] Improve and extend Hazelcast Jet based Java Runner

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

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

commit 5ccaa72a029eaee8a930fccbe0099afc645fa67e
Merge: 8bf45e9 7d62bb0
Author: Maximilian Michels <mx...@apache.org>
AuthorDate: Mon May 20 18:41:29 2019 +0200

    Merge pull request #8592: [BEAM-7305] Improve and extend Hazelcast Jet based Java Runner

 runners/jet-experimental/build.gradle              |   6 -
 .../org/apache/beam/runners/jet/DAGBuilder.java    |  41 ++-
 .../apache/beam/runners/jet/JetGraphVisitor.java   |  11 +-
 .../beam/runners/jet/JetPipelineOptions.java       |  14 +-
 .../apache/beam/runners/jet/JetPipelineResult.java |  95 ++++---
 .../org/apache/beam/runners/jet/JetRunner.java     | 155 +++++++-----
 .../beam/runners/jet/JetTransformTranslators.java  | 118 ++++-----
 .../java/org/apache/beam/runners/jet/Utils.java    |  65 ++++-
 .../beam/runners/jet/metrics/JetMetricResults.java | 181 ++++++++-----
 .../runners/jet/metrics/JetMetricsContainer.java   |  25 +-
 .../runners/jet/processors/AbstractParDoP.java     |  18 +-
 .../beam/runners/jet/processors/AssignWindowP.java |   9 +-
 .../runners/jet/processors/BoundedSourceP.java     |  32 ++-
 .../beam/runners/jet/processors/FlattenP.java      |   2 +-
 .../runners/jet/processors/UnboundedSourceP.java   | 281 +++++++++++++++++++++
 .../apache/beam/runners/jet/processors/ViewP.java  |   2 +-
 .../beam/runners/jet/processors/WindowGroupP.java  | 121 ++++++---
 .../org/apache/beam/runners/jet/TestJetRunner.java | 100 +++++++-
 .../org/apache/beam/runners/jet}/TestStreamP.java  |  11 +-
 .../src/main/resources/archetype-resources/pom.xml |  13 +
 20 files changed, 917 insertions(+), 383 deletions(-)