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

Posted to commits@beam.apache.org by dh...@apache.org on 2017/05/11 22:12:17 UTC

[2/2] beam git commit: This closes #3081

This closes #3081


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/74bcc023
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/74bcc023
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/74bcc023

Branch: refs/heads/release-2.0.0
Commit: 74bcc02377ed85ba95efe3c9c65d1cb2afdd053c
Parents: e8e8a6e 608629a
Author: Dan Halperin <dh...@google.com>
Authored: Thu May 11 15:12:10 2017 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Thu May 11 15:12:10 2017 -0700

----------------------------------------------------------------------
 .../core/LateDataDroppingDoFnRunner.java        |  2 +-
 .../apache/beam/runners/core/LateDataUtils.java | 33 ++++++-
 .../beam/runners/core/ReduceFnRunner.java       | 43 +++-------
 .../beam/runners/core/SimpleDoFnRunner.java     |  2 +-
 .../beam/runners/core/StatefulDoFnRunner.java   |  6 +-
 .../apache/beam/runners/core/WatermarkHold.java |  9 +-
 .../beam/runners/core/LateDataUtilsTest.java    | 90 ++++++++++++++++++++
 .../beam/sdk/transforms/ReifyTimestamps.java    |  6 ++
 .../apache/beam/sdk/transforms/Reshuffle.java   | 29 ++++---
 .../sdk/transforms/ReifyTimestampsTest.java     | 36 ++++++++
 .../beam/sdk/transforms/ReshuffleTest.java      | 27 ++++++
 11 files changed, 234 insertions(+), 49 deletions(-)
----------------------------------------------------------------------