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 2fbc4c3 Merge pull request #6798: [BEAM-5833] Fix checkstyle breakage
add 5751d49 [SQL] Move builtin aggregations creation to a map of factories
add 2649207 [SQL] Simplify AggregationRel
add 5fbc2b9 [SQL] Add AggregationCall wrapper
add a998596 [SQL] Inline aggregation rel helper transforms
add 8f7608e [SQL] Move CombineFn creation to AggregationCall constructor
add 6ea49ad [SQL] Split and rename Aggregation CombineFn wrappers
add d6cfc06 [SQL] Make AggregationCombineFnAdapter non-AutoValue
add bb82e44 [SQL] Convert ifs to guard statements in
AggregationCombineFnAdapter
add 3fbdd02 [SQL] Convert Covariance to accept rows instead of KVs
add 3292271 [SQL] Split Args Adapters from AggregationCombineFnAdapter
add 19ec3d2 [SQL] Extract MultipleAggregationFn from
BeamAggregationTransforms
add 301b0c9 [SQL] Clean up, comment aggregation transforms
new c0a9dff Merge pull request #6770 from akedin/aggregations-refactor
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:
.../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(-)
delete mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/BeamAggregationTransforms.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/MultipleAggregationsFn.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/agg/AggregationArgsAdapter.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/agg/AggregationCombineFnAdapter.java
delete mode 100644
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/schema/transform/BeamAggregationTransformTest.java
