This is an automated email from the ASF dual-hosted git repository. jark pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from d544d30 [FLINK-13600][table] Rework TableEnvironment.connect() class hierarchy new 4d560df [FLINK-13523][table-planner-blink] Refactor DIVIDE function to keep it compatible with old planner new fbd3225 [FLINK-13523][table-planner-blink] Remove non-standard bitwise scalar function and DIV(), DIV_INT() function from blink planner new 421f0a5 [FLINK-13523][table-planner-blink] Refactor AVG aggregate function to keep it compatible with old planner The 3 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: .../functions/aggfunctions/AvgAggFunction.java | 83 +++++++++++++- .../aggfunctions/DeclarativeAggregateFunction.java | 3 + .../functions/sql/FlinkSqlOperatorTable.java | 74 +----------- .../table/planner/calcite/FlinkTypeSystem.scala | 2 +- .../codegen/agg/DeclarativeAggCodeGen.scala | 2 +- .../codegen/agg/batch/AggCodeGenHelper.scala | 1 - .../codegen/agg/batch/HashAggCodeGenHelper.scala | 1 - .../planner/codegen/calls/FunctionGenerator.scala | 109 ------------------ .../planner/expressions/ReturnTypeInference.scala | 5 +- .../plan/rules/logical/SplitAggregateRule.scala | 23 +++- .../planner/plan/utils/AggFunctionFactory.scala | 15 ++- .../table/planner/codegen/agg/TestLongAvgFunc.java | 6 +- .../planner/plan/batch/sql/RemoveCollationTest.xml | 4 +- .../planner/plan/batch/sql/RemoveShuffleTest.xml | 12 +- .../planner/plan/batch/sql/SubplanReuseTest.xml | 10 +- .../batch/sql/agg/AggregateReduceGroupingTest.xml | 12 +- .../plan/batch/sql/agg/HashAggregateTest.xml | 12 +- .../plan/batch/sql/agg/OverAggregateTest.xml | 20 ++-- .../plan/batch/sql/agg/SortAggregateTest.xml | 12 +- .../plan/batch/sql/agg/WindowAggregateTest.xml | 18 +-- .../logical/AggregateReduceGroupingRuleTest.xml | 12 +- .../plan/rules/logical/SplitAggregateRuleTest.xml | 4 +- .../rules/logical/WindowGroupReorderRuleTest.xml | 24 ++-- .../logical/subquery/SubQuerySemiJoinTest.xml | 16 ++- .../planner/plan/stream/sql/agg/AggregateTest.xml | 4 +- .../plan/stream/sql/agg/DistinctAggregateTest.xml | 12 +- .../stream/sql/agg/IncrementalAggregateTest.xml | 4 +- .../plan/stream/sql/agg/OverAggregateTest.xml | 4 +- .../plan/stream/sql/agg/WindowAggregateTest.xml | 6 +- .../planner/plan/stream/table/GroupWindowTest.xml | 4 +- .../table/planner/codegen/agg/AggTestBase.scala | 9 +- .../codegen/agg/AggsHandlerCodeGeneratorTest.scala | 13 +-- .../codegen/agg/batch/AggWithoutKeysTest.scala | 9 +- .../codegen/agg/batch/BatchAggTestBase.scala | 8 +- .../agg/batch/HashAggCodeGeneratorTest.scala | 13 +-- .../agg/batch/SortAggCodeGeneratorTest.scala | 8 +- .../planner/expressions/ScalarFunctionsTest.scala | 65 +---------- .../planner/expressions/SqlExpressionTest.scala | 28 +---- .../metadata/AggCallSelectivityEstimatorTest.scala | 2 - .../FlinkRelMdFilteredColumnIntervalTest.scala | 5 +- .../planner/runtime/batch/sql/DecimalITCase.scala | 19 ---- .../planner/runtime/batch/sql/MiscITCase.scala | 2 +- .../runtime/batch/sql/OverWindowITCase.scala | 120 ++++++++++---------- .../batch/sql/agg/AggregateITCaseBase.scala | 26 ++--- .../sql/agg/AggregateReduceGroupingITCase.scala | 32 +++--- .../runtime/batch/sql/agg/GroupingSetsITCase.scala | 120 ++++++++++---------- .../batch/sql/agg/WindowAggregateITCase.scala | 44 ++++---- .../runtime/batch/table/AggregationITCase.scala | 18 +-- .../runtime/stream/sql/AggregateITCase.scala | 12 +- .../runtime/stream/sql/MatchRecognizeITCase.scala | 2 +- .../runtime/stream/sql/OverWindowITCase.scala | 124 ++++++++++----------- .../planner/runtime/stream/sql/RankITCase.scala | 8 +- .../runtime/stream/sql/SplitAggregateITCase.scala | 4 +- .../runtime/stream/table/AggregateITCase.scala | 6 +- .../runtime/stream/table/GroupWindowITCase.scala | 10 +- .../stream/table/MiniBatchGroupWindowITCase.scala | 8 +- .../runtime/stream/table/OverWindowITCase.scala | 32 +++--- .../flink/table/planner/utils/AvgAggFunction.scala | 24 ++-- 58 files changed, 541 insertions(+), 744 deletions(-)