This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from ed6de585481 [FLINK-37092][e2e] Add adaptive skewed join optimization
to e2e tpc-ds tests
add 55de8d683cc [FLINK-37076][table-planner] Make table arguments explicit
in logical plans
No new revisions were added by this update.
Summary of changes:
.../apache/calcite/sql2rel/SqlToRelConverter.java | 28 +-
.../planner/calcite/FlinkConvertletTable.java | 111 ++++----
.../table/planner/calcite/FlinkSqlCallBinding.java | 5 +-
...emanticsTableCall.java => RexTableArgCall.java} | 60 +++--
...ultOperator.java => SqlDefaultArgOperator.java} | 9 +-
.../planner/functions/sql/SqlTableArgOperator.java | 31 ++-
.../ProjectWindowTableFunctionTransposeRule.java | 35 ++-
.../planner/codegen/calls/StringCallGen.scala | 4 +-
.../StreamPhysicalWindowTableFunctionRule.scala | 14 +-
.../table/planner/plan/utils/WindowUtil.scala | 47 ++--
.../table/planner/catalog/JavaCatalogTableTest.xml | 2 +-
.../plan/batch/sql/WindowTableFunctionTest.xml | 18 +-
.../nodes/exec/operator/StreamOperatorNameTest.xml | 24 +-
.../table/planner/plan/optimize/ScanReuseTest.xml | 8 +-
...ProjectWindowTableFunctionTransposeRuleTest.xml | 8 +-
.../ExpandWindowTableFunctionTransposeRuleTest.xml | 6 +-
.../planner/plan/stream/sql/MatchRecognizeTest.xml | 2 +-
.../plan/stream/sql/WindowDeduplicateTest.xml | 16 +-
.../planner/plan/stream/sql/WindowRankTest.xml | 26 +-
.../plan/stream/sql/WindowTableFunctionTest.xml | 40 +--
.../plan/stream/sql/agg/WindowAggregateTest.xml | 286 ++++++++++-----------
.../plan/stream/sql/join/WindowJoinTest.xml | 240 ++++++++---------
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 3 +-
23 files changed, 511 insertions(+), 512 deletions(-)
rename
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/{RexSetSemanticsTableCall.java
=> RexTableArgCall.java} (56%)
rename
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/sql/{SqlDefaultOperator.java
=> SqlDefaultArgOperator.java} (85%)
copy
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParserIN.java
=>
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/sql/SqlTableArgOperator.java
(52%)
