This closes #2334
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/434eadb5 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/434eadb5 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/434eadb5 Branch: refs/heads/master Commit: 434eadb53ed19e2ee07526861c06280729824124 Parents: d35e1b0 25569ea Author: Amit Sela <amitsel...@gmail.com> Authored: Tue Mar 28 16:45:55 2017 +0300 Committer: Amit Sela <amitsel...@gmail.com> Committed: Tue Mar 28 16:45:55 2017 +0300 ---------------------------------------------------------------------- .../SparkGroupAlsoByWindowViaWindowSet.java | 35 ++- .../translation/GroupCombineFunctions.java | 38 ++- .../spark/translation/TranslationUtils.java | 245 +++++++++++++++---- 3 files changed, 248 insertions(+), 70 deletions(-) ----------------------------------------------------------------------
