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:27 UTC

[beam] 01/01: Merge pull request #5932: Changes SDF key type again to bytes

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(-)