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/05/14 22:07:00 UTC

[beam] 01/01: [BEAM-4269, BEAM-3970] Implement AssignWindows in the Java SDK harness

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 f0aa75fbd8e07f438d0662f297bed18194adcc8b
Merge: 060c512 0530cb7
Author: Lukasz Cwik <lc...@google.com>
AuthorDate: Mon May 14 15:06:54 2018 -0700

    [BEAM-4269, BEAM-3970] Implement AssignWindows in the Java SDK harness

 .../beam/fn/harness/AssignWindowsRunner.java       | 111 +++++++
 .../org/apache/beam/fn/harness/MapFnRunner.java    | 120 -------
 .../org/apache/beam/fn/harness/MapFnRunners.java   | 180 ++++++++++
 .../beam/fn/harness/WindowMappingFnRunner.java     |  19 +-
 .../beam/fn/harness/AssignWindowsRunnerTest.java   | 369 +++++++++++++++++++++
 .../apache/beam/fn/harness/MapFnRunnerTest.java    |  97 ------
 .../apache/beam/fn/harness/MapFnRunnersTest.java   | 185 +++++++++++
 7 files changed, 855 insertions(+), 226 deletions(-)

-- 
To stop receiving notification emails like this one, please contact
lcwik@apache.org.