You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by dm...@apache.org on 2020/12/16 09:00:57 UTC

[beam] branch master updated (f87c984 -> 56d4ac9)

This is an automated email from the ASF dual-hosted git repository.

dmvk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from f87c984  Merge pull request #13470 from [BEAM-10114] Convert PubsubLiteIO read to use SplittableDoFn.
     add dee8d49  [BEAM-11443] Implement byte-based GBK for Flink Streaming Runner.
     add 56d4ac9  Merge pull request #13538: [BEAM-11443] Implement byte-based GBK for Flink Streaming Runner.

No new revisions were added by this update.

Summary of changes:
 .../FlinkStreamingPortablePipelineTranslator.java  |  23 +--
 .../flink/FlinkStreamingTransformTranslators.java  | 189 ++++++++++++++-------
 .../flink/FlinkStreamingTranslationContext.java    |  10 +-
 .../wrappers/streaming/DoFnOperator.java           |   5 +-
 .../streaming/SingletonKeyedWorkItemCoder.java     |  13 +-
 .../wrappers/streaming/WorkItemKeySelector.java    |   4 +-
 .../wrappers/streaming/WindowDoFnOperatorTest.java |   2 +-
 7 files changed, 152 insertions(+), 94 deletions(-)