[BEAM-2204] This closes #3527
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a96c3a01 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a96c3a01 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a96c3a01 Branch: refs/heads/DSL_SQL Commit: a96c3a01f18826b4e43ad7e8f26e94c02903acd9 Parents: aa265e6 eb589fb Author: Tyler Akidau <[email protected]> Authored: Wed Jul 12 09:49:59 2017 -0700 Committer: Tyler Akidau <[email protected]> Committed: Wed Jul 12 09:49:59 2017 -0700 ---------------------------------------------------------------------- .../interpreter/operator/BeamSqlPrimitive.java | 4 +++ .../beam/dsls/sql/rel/BeamAggregationRel.java | 2 +- .../transform/BeamAggregationTransforms.java | 8 ++++- .../dsls/sql/BeamSqlDslAggregationTest.java | 35 +++++++++++++++----- .../transform/BeamAggregationTransformTest.java | 2 +- 5 files changed, 39 insertions(+), 12 deletions(-) ----------------------------------------------------------------------
