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

Posted to commits@beam.apache.org by lc...@apache.org on 2018/09/10 18:23:21 UTC

[beam] 01/01: [BEAM-5149] Add support for the Java SDK harness to merge windows.

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

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

commit 883f01536440bdf9b582d785b6e609a4a90cfdff
Merge: 9b68f92 def076e
Author: Lukasz Cwik <lc...@google.com>
AuthorDate: Mon Sep 10 11:23:15 2018 -0700

    [BEAM-5149] Add support for the Java SDK harness to merge windows.

 .../pipeline/src/main/proto/beam_runner_api.proto  |  30 +++-
 .../construction/WindowingStrategyTranslation.java |  15 +-
 .../beam/fn/harness/WindowMappingFnRunner.java     |  14 +-
 .../beam/fn/harness/WindowMergingFnRunner.java     | 158 +++++++++++++++++++++
 .../beam/fn/harness/WindowMergingFnRunnerTest.java | 121 ++++++++++++++++
 5 files changed, 329 insertions(+), 9 deletions(-)