This closes #265
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/34e05954 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/34e05954 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/34e05954 Branch: refs/heads/master Commit: 34e05954dc70610cb519348dc6b7ced1934bf574 Parents: 69ec223 dff82ca Author: Kenneth Knowles <[email protected]> Authored: Mon May 2 20:07:35 2016 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Mon May 2 20:07:35 2016 -0700 ---------------------------------------------------------------------- .../direct/InMemoryWatermarkManager.java | 19 +- .../direct/InProcessEvaluationContext.java | 6 +- .../direct/InMemoryWatermarkManagerTest.java | 368 ++++++++++++------- 3 files changed, 252 insertions(+), 141 deletions(-) ----------------------------------------------------------------------
