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 c0a9dffd17d1f24a560b4513ca391d0b8bb56bfe
Merge: 2fbc4c3 301b0c9
Author: Anton Kedin <33067037+ake...@users.noreply.github.com>
AuthorDate: Tue Oct 23 18:20:12 2018 -0400

    Merge pull request #6770 from akedin/aggregations-refactor
    
    [SQL] Aggregations refactor

 .../sql/impl/rel/BeamAggregationRel.java           | 173 ++++--
 .../impl/transform/BeamAggregationTransforms.java  | 353 -------------
 .../impl/transform/BeamBuiltinAggregations.java    | 106 ++--
 .../sql/impl/transform/MultipleAggregationsFn.java | 175 +++++++
 .../impl/transform/agg/AggregationArgsAdapter.java | 168 ++++++
 .../transform/agg/AggregationCombineFnAdapter.java | 141 +++++
 .../sql/impl/transform/agg/CovarianceFn.java       |  26 +-
 .../sql/impl/transform/agg/VarianceFn.java         |  10 +
 .../transform/BeamAggregationTransformTest.java    | 582 ---------------------
 9 files changed, 695 insertions(+), 1039 deletions(-)

Reply via email to