beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From d...@apache.org
Subject [beam] branch master updated (f87c984 -> 56d4ac9)
Date Wed, 16 Dec 2020 09:00:57 GMT
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(-)


Mime
View raw message