Repository: beam Updated Branches: refs/heads/master e92ac6fed -> 171befaee
This closes #3080 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/171befae Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/171befae Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/171befae Branch: refs/heads/master Commit: 171befaee93eacaaed2a6c72fc0c8fc5ce21227e Parents: e92ac6f dbb850c Author: Thomas Groh <[email protected]> Authored: Thu May 11 14:56:17 2017 -0700 Committer: Thomas Groh <[email protected]> Committed: Thu May 11 14:56:17 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(-) ----------------------------------------------------------------------
