You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/05/10 18:32:05 UTC
[2/2] incubator-beam git commit: Closes #312
Closes #312
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/874ddef0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/874ddef0
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/874ddef0
Branch: refs/heads/master
Commit: 874ddef05a00060b1830722271e0678c463e68c7
Parents: 4870525 46bc6e1
Author: Kenneth Knowles <kl...@google.com>
Authored: Tue May 10 11:31:51 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Tue May 10 11:31:51 2016 -0700
----------------------------------------------------------------------
.../direct/InMemoryWatermarkManager.java | 113 +++++++++++++++----
.../direct/InProcessEvaluationContext.java | 14 ++-
.../direct/WatermarkCallbackExecutor.java | 9 +-
.../direct/InMemoryWatermarkManagerTest.java | 58 ++++++++--
.../direct/InProcessEvaluationContextTest.java | 8 +-
.../direct/WatermarkCallbackExecutorTest.java | 4 +-
6 files changed, 169 insertions(+), 37 deletions(-)
----------------------------------------------------------------------