This is an automated email from the ASF dual-hosted git repository. apilloud pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git.
from f386050 Merge pull request #6383 from apilloud/null add 3532ae7 Simplify BeamAggregationRule add 1b420e8 Fully explain BeamAggregationRel add 46e3c98 Simplify project with Aggregation add 4c8645c Remove unneeded CalcWindow new 2940915 Merge pull request #6382 from apilloud/sqlagg 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/interpreter/BeamSqlFnExecutor.java | 18 --- .../operator/BeamSqlWindowEndExpression.java | 50 ------- .../operator/BeamSqlWindowExpression.java | 53 ------- .../operator/BeamSqlWindowStartExpression.java | 51 ------- .../sql/impl/rel/BeamAggregationRel.java | 69 ++++++++-- .../sdk/extensions/sql/impl/rel/BeamCalcRel.java | 6 +- .../sql/impl/rule/AggregateWindowFactory.java | 152 --------------------- .../sql/impl/rule/AggregateWindowField.java | 51 ------- .../sql/impl/rule/BeamAggregationRule.java | 130 ++++++++++++++++-- 9 files changed, 179 insertions(+), 401 deletions(-) delete mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/interpreter/operator/BeamSqlWindowEndExpression.java delete mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/interpreter/operator/BeamSqlWindowExpression.java delete mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/interpreter/operator/BeamSqlWindowStartExpression.java delete mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/AggregateWindowFactory.java delete mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/AggregateWindowField.java