Repository: incubator-beam Updated Branches: refs/heads/master 9de9ce69f -> c6d9bf297
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/master Commit: c6d9bf29700d6f13a33423183201a18525040e05 Parents: 9de9ce6 a58f1eb Author: Thomas Groh <[email protected]> Authored: Mon Nov 7 15:47:02 2016 -0800 Committer: Thomas Groh <[email protected]> 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(-) ----------------------------------------------------------------------
