This is an automated email from the ASF dual-hosted git repository.
mxm pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from ecfb432 Merge pull request #8729: [BEAM-7465] Upgrade Jackson to
version 2.9.9
add 14bd7a6 Make metrics flush periodically
add f4987e2 Rename pipeline option for parallelism
add d6884d6 Make improvements in documentation
add 52443d7 Add support for running "NeedsRunner" category of tests
add 143efd8 Make cooperative ParDo execution an option, when possible
add 41c865e Remove previous edge optimization, it's not playing well with
file-write sinks
add 570ad98 Make ParDoLifecycleTest less restrictive
add 25227c3 Make IMPULSE work in Jet Runner
new ab6b65e Merge pull request #8699: [BEAM-7305] Fix issues in and
extend documentation for Hazelcast Jet Runner
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
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(-)
