You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by ta...@apache.org on 2017/08/12 00:14:12 UTC

[2/2] beam git commit: [BEAM-2747] This closes #3716

[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 <ta...@apache.org>
Authored: Fri Aug 11 17:12:29 2017 -0700
Committer: Tyler Akidau <ta...@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(-)
----------------------------------------------------------------------