This closes #3840
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/50532f0a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/50532f0a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/50532f0a Branch: refs/heads/master Commit: 50532f0a92d7ce8dbbdc6c3179ab7b9efde6a746 Parents: 8d71ebf c3d4c5d Author: Stas Levin <stasle...@apache.org> Authored: Wed Sep 13 11:04:20 2017 +0300 Committer: Stas Levin <stasle...@apache.org> Committed: Wed Sep 13 11:04:20 2017 +0300 ---------------------------------------------------------------------- .../SparkGroupAlsoByWindowViaWindowSet.java | 82 +++++++++++++------- .../spark/stateful/SparkTimerInternals.java | 15 ---- 2 files changed, 56 insertions(+), 41 deletions(-) ----------------------------------------------------------------------