[BEAM-2287] This closes #3447
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7ba77dd4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7ba77dd4 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7ba77dd4 Branch: refs/heads/DSL_SQL Commit: 7ba77dd435eefd697fd0a452b07e0154dd1cd1b2 Parents: 2096da2 a13fce9 Author: Tyler Akidau <[email protected]> Authored: Fri Jun 30 15:40:05 2017 -0700 Committer: Tyler Akidau <[email protected]> Committed: Fri Jun 30 15:40:05 2017 -0700 ---------------------------------------------------------------------- .../org/apache/beam/dsls/sql/BeamSqlEnv.java | 10 + .../beam/dsls/sql/rel/BeamAggregationRel.java | 2 +- .../beam/dsls/sql/schema/BeamSqlUdaf.java | 72 ++ .../transform/BeamAggregationTransforms.java | 658 ++++--------------- .../sql/transform/BeamBuiltinAggregations.java | 412 ++++++++++++ .../transform/BeamAggregationTransformTest.java | 2 +- 6 files changed, 633 insertions(+), 523 deletions(-) ----------------------------------------------------------------------
