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(-)
