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/11/08 03:41:42 UTC
[43/50] incubator-beam git commit: This closes #1287
This closes #1287
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c6d9bf29
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c6d9bf29
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/c6d9bf29
Branch: refs/heads/gearpump-runner
Commit: c6d9bf29700d6f13a33423183201a18525040e05
Parents: 9de9ce6 a58f1eb
Author: Thomas Groh <tg...@google.com>
Authored: Mon Nov 7 15:47:02 2016 -0800
Committer: Thomas Groh <tg...@google.com>
Committed: Mon Nov 7 15:47:02 2016 -0800
----------------------------------------------------------------------
.../beam/runners/direct/DirectRunner.java | 5 +
.../direct/ImmutableListBundleFactory.java | 21 ++-
.../beam/runners/direct/WatermarkManager.java | 153 +++++++++++++------
.../direct/ImmutableListBundleFactoryTest.java | 15 +-
4 files changed, 141 insertions(+), 53 deletions(-)
----------------------------------------------------------------------