This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 060c512 Merge pull request #5355: Fix error-prone warnings and
multiple cleanups based on static analysis for CassandraIO
add f4ecff1 Enable MapFnRunner to provide full WindowedValues
add 0530cb7 Implement AssignWindows in the Java SDK Harness
new f0aa75f [BEAM-4269, BEAM-3970] Implement AssignWindows in the Java
SDK harness
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../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(-)
create mode 100644
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/AssignWindowsRunner.java
delete mode 100644
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/MapFnRunner.java
create mode 100644
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/MapFnRunners.java
create mode 100644
sdks/java/harness/src/test/java/org/apache/beam/fn/harness/AssignWindowsRunnerTest.java
delete mode 100644
sdks/java/harness/src/test/java/org/apache/beam/fn/harness/MapFnRunnerTest.java
create mode 100644
sdks/java/harness/src/test/java/org/apache/beam/fn/harness/MapFnRunnersTest.java
--
To stop receiving notification emails like this one, please contact
[email protected].
