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/31 14:30:46 UTC

[beam] 01/01: Merge pull request #8699: [BEAM-7305] Fix issues in and extend documentation for Hazelcast Jet 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 ab6b65e149a1b9fc20552f4ea5421ced46cdc551
Merge: ecfb432 25227c3
Author: Maximilian Michels <mx...@apache.org>
AuthorDate: Fri May 31 16:30:28 2019 +0200

    Merge pull request #8699: [BEAM-7305] Fix issues in and extend documentation for Hazelcast Jet Runner

 runners/jet-experimental/build.gradle              | 39 ++++++++--
 .../org/apache/beam/runners/jet/DAGBuilder.java    | 25 ++++---
 .../beam/runners/jet/JetPipelineOptions.java       | 13 +++-
 .../org/apache/beam/runners/jet/JetRunner.java     |  2 +-
 .../beam/runners/jet/JetTransformTranslators.java  |  5 +-
 .../runners/jet/metrics/JetMetricsContainer.java   | 14 +++-
 .../runners/jet/processors/AbstractParDoP.java     | 47 +++++++++---
 .../beam/runners/jet/processors/ImpulseP.java      | 79 +++++++++++++++++---
 .../beam/sdk/transforms/ParDoLifecycleTest.java    | 11 ++-
 website/src/documentation/runners/jet.md           | 83 ++++++++++++++++++----
 website/src/get-started/quickstart-java.md         | 12 +++-
 11 files changed, 269 insertions(+), 61 deletions(-)