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:16 UTC

[beam] branch master updated (401d663 -> d8a5faa)

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

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


    from 401d663  Merge pull request #6853: [SQL] Test NULL in Pubsub JSON format
     add be6942e  Switch SQL over to use the new Beam Group transform.
     new d8a5faa  Merge pull request #6856 from reuvenlax/sql_use_group

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../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(-)
 delete mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/MultipleAggregationsFn.java
 delete mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/agg/AggregationArgsAdapter.java

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

Posted by an...@apache.org.
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(-)