This is an automated email from the ASF dual-hosted git repository.
jchan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 2c5078bc905 [FLINK-34987][state] Implement Async Value State (#24651)
add 43a3d50ce39 [FLINK-34633][table] Support unnesting array constants
No new revisions were added by this update.
Summary of changes:
.../logical/UncollectToTableFunctionScanRule.java | 135 ++++++++++++++++++++
.../planner/plan/rules/FlinkBatchRuleSets.scala | 1 +
.../planner/plan/rules/FlinkStreamRuleSets.scala | 1 +
.../table/planner/plan/utils/CorrelateUtil.scala | 142 ---------------------
.../table/planner/plan/batch/sql/UnnestTest.xml | 21 ++-
.../plan/rules/logical/LogicalUnnestRuleTest.xml | 21 +++
.../table/planner/plan/stream/sql/UnnestTest.xml | 21 ++-
.../table/planner/plan/common/UnnestTestBase.scala | 5 +
.../planner/runtime/batch/sql/UnnestITCase.scala | 12 ++
.../planner/runtime/stream/sql/UnnestITCase.scala | 23 ++++
10 files changed, 238 insertions(+), 144 deletions(-)
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/UncollectToTableFunctionScanRule.java
delete mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/CorrelateUtil.scala
