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
