You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2022/02/09 17:22:26 UTC
[flink] branch master updated (a8b2f17 -> f3f9889)
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 a8b2f17 [FLINK-25841][table] Add helpful JavaDocs at various locations
add f3f9889 [FLINK-26044][table] Properly declare an internal UNNEST function
No new revisions were added by this update.
Summary of changes:
.../table/functions/BuiltInFunctionDefinition.java | 16 +--
.../functions/BuiltInFunctionDefinitions.java | 10 ++
.../plan/rules/logical/LogicalUnnestRule.scala | 22 ++---
.../table/planner/plan/batch/sql/UnnestTest.xml | 20 ++--
.../plan/rules/logical/LogicalUnnestRuleTest.xml | 20 ++--
.../table/planner/plan/stream/sql/UnnestTest.xml | 20 ++--
.../functions/BuiltInSpecializedFunction.java} | 32 ++++--
.../UnnestRowsFunction.java} | 107 +++++++++++----------
8 files changed, 142 insertions(+), 105 deletions(-)
copy flink-table/{flink-table-api-java/src/test/java/org/apache/flink/table/functions/TestSimpleUDF.java => flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/BuiltInSpecializedFunction.java} (51%)
rename flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/{SqlUnnestUtils.java => table/UnnestRowsFunction.java} (63%)