Repository: beam Updated Branches: refs/heads/master 960f3e660 -> 25b52c5ac
This closes #2246 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/25b52c5a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/25b52c5a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/25b52c5a Branch: refs/heads/master Commit: 25b52c5acc3dddf8ee979b1b7a8c201b68c3f268 Parents: 960f3e6 58cc359 Author: Thomas Groh <tg...@google.com> Authored: Thu Mar 16 16:39:47 2017 -0700 Committer: Thomas Groh <tg...@google.com> Committed: Thu Mar 16 16:39:47 2017 -0700 ---------------------------------------------------------------------- .../apache/beam/sdk/util/ReifyTimestamps.java | 76 +++++++++++++ .../org/apache/beam/sdk/util/Reshuffle.java | 19 ++-- .../beam/sdk/util/ReifyTimestampsTest.java | 109 +++++++++++++++++++ .../org/apache/beam/sdk/util/ReshuffleTest.java | 70 +++++++++++- 4 files changed, 265 insertions(+), 9 deletions(-) ----------------------------------------------------------------------
