This closes #1021
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a1ac2222 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a1ac2222 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/a1ac2222 Branch: refs/heads/master Commit: a1ac2222dca13f6902faad30f37a877c1e6fb218 Parents: b5853a6 59f6231 Author: Maximilian Michels <m...@apache.org> Authored: Wed Sep 28 18:46:58 2016 +0200 Committer: Maximilian Michels <m...@apache.org> Committed: Wed Sep 28 18:46:58 2016 +0200 ---------------------------------------------------------------------- .../wrappers/streaming/WindowDoFnOperator.java | 179 +++++++++++++++++-- 1 file changed, 165 insertions(+), 14 deletions(-) ----------------------------------------------------------------------