This closes #3568
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/417ff43c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/417ff43c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/417ff43c Branch: refs/heads/DSL_SQL Commit: 417ff43c09a50071dcd2e88b091c31b9217c2340 Parents: c6f1f9f c26cbea Author: mingmxu <[email protected]> Authored: Tue Aug 29 13:34:00 2017 -0700 Committer: mingmxu <[email protected]> Committed: Tue Aug 29 13:34:00 2017 -0700 ---------------------------------------------------------------------- .../transform/BeamAggregationTransforms.java | 8 + .../impl/transform/BeamBuiltinAggregations.java | 433 +++++++++++++++---- .../sql/BeamSqlDslAggregationTest.java | 119 ++++- 3 files changed, 461 insertions(+), 99 deletions(-) ----------------------------------------------------------------------
