[BEAM-2747] This closes #3716
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9eec6a03 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9eec6a03 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9eec6a03 Branch: refs/heads/DSL_SQL Commit: 9eec6a030a4d14b504730b57a8d863a5bd97468e Parents: f37a7a1 1770c86 Author: Tyler Akidau <taki...@apache.org> Authored: Fri Aug 11 17:12:29 2017 -0700 Committer: Tyler Akidau <taki...@apache.org> Committed: Fri Aug 11 17:12:29 2017 -0700 ---------------------------------------------------------------------- .../apache/beam/sdk/coders/BeamRecordCoder.java | 16 +- .../apache/beam/sdk/extensions/sql/BeamSql.java | 22 +- .../beam/sdk/extensions/sql/BeamSqlEnv.java | 11 +- .../operator/BeamSqlInputRefExpression.java | 4 + .../sql/impl/interpreter/operator/UdafImpl.java | 87 ++++ .../transform/BeamAggregationTransforms.java | 44 +- .../impl/transform/BeamBuiltinAggregations.java | 504 +++++++------------ .../sdk/extensions/sql/schema/BeamSqlUdaf.java | 72 --- .../extensions/sql/BeamSqlDslUdfUdafTest.java | 22 +- 9 files changed, 344 insertions(+), 438 deletions(-) ----------------------------------------------------------------------