This closes #2160
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/34b38ef9 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/34b38ef9 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/34b38ef9 Branch: refs/heads/master Commit: 34b38ef952b1981e82c0c74e0ee22b3d570169d4 Parents: 69d9512 d8bc618 Author: Sela <ans...@paypal.com> Authored: Mon Mar 6 11:19:48 2017 +0200 Committer: Sela <ans...@paypal.com> Committed: Mon Mar 6 11:19:48 2017 +0200 ---------------------------------------------------------------------- .../translation/GroupCombineFunctions.java | 22 ++++++++++++ .../spark/translation/TransformTranslator.java | 38 +++++++++++++++----- .../spark/translation/TranslationUtils.java | 10 ++++++ .../streaming/StreamingTransformTranslator.java | 36 +++++++++++++++++++ 4 files changed, 97 insertions(+), 9 deletions(-) ----------------------------------------------------------------------
