This is an automated email from the ASF dual-hosted git repository.
yuxia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 379e4910547 [FLINK-32232][table] Supports parse truncate table
statement (#22691)
add 79b06cf9538 [FLINK-31677][table] Add built-in MAP_ENTRIES function.
(#22312)
No new revisions were added by this update.
Summary of changes:
docs/data/sql_functions.yml | 3 +
.../docs/reference/pyflink.table/expressions.rst | 1 +
flink-python/pyflink/table/expression.py | 13 +++-
.../flink/table/api/internal/BaseExpressions.java | 6 ++
.../functions/BuiltInFunctionDefinitions.java | 19 ++++-
.../strategies/SpecificInputTypeStrategies.java | 34 +--------
.../strategies/SpecificTypeStrategies.java | 53 ++++++++++++++
.../table/planner/functions/MapFunctionITCase.java | 83 +++++++++++++++++++++-
.../functions/scalar/MapEntriesFunction.java | 65 +++++++++++++++++
9 files changed, 236 insertions(+), 41 deletions(-)
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/MapEntriesFunction.java
