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

Posted to commits@beam.apache.org by an...@apache.org on 2018/10/27 05:40:17 UTC

[beam] 01/01: Merge pull request #6856 from reuvenlax/sql_use_group

This is an automated email from the ASF dual-hosted git repository.

anton pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit d8a5faa4fe91d910517fb091fade0a2ad4b40c5f
Merge: 401d663 be6942e
Author: Anton Kedin <33...@users.noreply.github.com>
AuthorDate: Sat Oct 27 01:40:09 2018 -0400

    Merge pull request #6856 from reuvenlax/sql_use_group
    
    [BEAM-4461] Switch SQL over to use the new Beam Group transform.

 .../apache/beam/sdk/schemas/transforms/Group.java  | 142 +++++++++++++++
 .../sql/impl/rel/BeamAggregationRel.java           | 129 +++++++-------
 .../sql/impl/transform/MultipleAggregationsFn.java | 175 -------------------
 .../impl/transform/agg/AggregationArgsAdapter.java | 171 ------------------
 .../transform/agg/AggregationCombineFnAdapter.java | 193 ++++++++++++---------
 5 files changed, 308 insertions(+), 502 deletions(-)