This is an automated email from the ASF dual-hosted git repository.
jkff pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from c5c20b6 Merge pull request #5785: [BEAM-4641] Samza runner postcommit
status in PR template
add 34edbd5 [BEAM-4689] Reverts change of SDF key type
new 2820bab Merge pull request #5834: [BEAM-4689] Reverts change of SDF
key type
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:
examples/java/build.gradle | 1 +
.../org/apache/beam/examples/MinimalWordCount.java | 88 +++++++---------------
.../translation/operators/ApexParDoOperator.java | 12 +--
.../runners/core/construction/SplittableParDo.java | 13 ++--
.../apache/beam/runners/core/ProcessFnRunner.java | 16 ++--
.../core/SplittableParDoViaKeyedWorkItems.java | 32 ++++----
.../runners/core/SplittableParDoProcessFnTest.java | 9 +--
.../SplittableProcessElementsEvaluatorFactory.java | 14 ++--
.../SplittableRemoteStageEvaluatorFactory.java | 10 +--
.../flink/FlinkStreamingTransformTranslators.java | 6 +-
.../wrappers/streaming/SplittableDoFnOperator.java | 18 ++---
11 files changed, 90 insertions(+), 129 deletions(-)
