You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by sc...@apache.org on 2018/10/18 16:02:26 UTC
[beam] branch master updated (61a9f71 -> d8977da7)
This is an automated email from the ASF dual-hosted git repository.
scott pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 61a9f71 Merge pull request #6717 [BEAM-5521] Re-use bundle processors across bundles.
add 841804a Changes SDF key type again to bytes
add 5cab5cd Merge remote-tracking branch 'upstream/master' into sdf-key-bytes
add 926ae48 Changes SDF key type again to bytes
new d8977da7 Merge pull request #5932: Changes SDF key type again to bytes
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:
.../translation/operators/ApexParDoOperator.java | 12 ++++----
.../runners/core/construction/SplittableParDo.java | 16 ++++++-----
.../construction/SplittableParDoNaiveBounded.java | 10 +++----
.../org/apache/beam/runners/core/DoFnRunners.java | 2 +-
.../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 | 20 +++++++-------
.../dataflow/worker/DataflowProcessFnRunner.java | 20 +++++++-------
.../worker/SplittableProcessFnFactory.java | 22 +++++++--------
13 files changed, 97 insertions(+), 92 deletions(-)
[beam] 01/01: Merge pull request #5932: Changes SDF key type again
to bytes
Posted by sc...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
scott pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit d8977da7ee474e4736e0e6587a97f9d9ea2dfc8e
Merge: 61a9f71 926ae48
Author: Scott Wegner <sc...@apache.org>
AuthorDate: Thu Oct 18 12:02:17 2018 -0400
Merge pull request #5932: Changes SDF key type again to bytes
.../translation/operators/ApexParDoOperator.java | 12 ++++----
.../runners/core/construction/SplittableParDo.java | 16 ++++++-----
.../construction/SplittableParDoNaiveBounded.java | 10 +++----
.../org/apache/beam/runners/core/DoFnRunners.java | 2 +-
.../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 | 20 +++++++-------
.../dataflow/worker/DataflowProcessFnRunner.java | 20 +++++++-------
.../worker/SplittableProcessFnFactory.java | 22 +++++++--------
13 files changed, 97 insertions(+), 92 deletions(-)