[GitHub] [flink] liuyongvs commented on a diff in pull request #22745: [FLINK-31691][table] Add built-in MAP_FROM_ENTRIES function.

liuyongvs commented on code in PR #22745: URL: https://github.com/apache/flink/pull/22745#discussion_r1255140408 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/MapFromEntriesFunction.java: ## @@ -0,0 +1,75 @@ +/* + * Licensed to

[GitHub] [flink] liuyongvs commented on a diff in pull request #22745: [FLINK-31691][table] Add built-in MAP_FROM_ENTRIES function.

liuyongvs commented on code in PR #22745: URL: https://github.com/apache/flink/pull/22745#discussion_r1254294018 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/MapFromEntriesFunction.java: ## @@ -0,0 +1,75 @@ +/* + * Licensed to

[GitHub] [flink] liuyongvs commented on a diff in pull request #22745: [FLINK-31691][table] Add built-in MAP_FROM_ENTRIES function.

liuyongvs commented on code in PR #22745: URL: https://github.com/apache/flink/pull/22745#discussion_r1251864756 ## flink-python/pyflink/table/expressions.py: ## @@ -503,6 +503,25 @@ def map_from_arrays(key, value) -> Expression: return _binary_op("mapFromArrays", key,

[GitHub] [flink] liuyongvs commented on a diff in pull request #22745: [FLINK-31691][table] Add built-in MAP_FROM_ENTRIES function.

liuyongvs commented on code in PR #22745: URL: https://github.com/apache/flink/pull/22745#discussion_r1251436429 ## flink-python/pyflink/table/expressions.py: ## @@ -503,6 +503,25 @@ def map_from_arrays(key, value) -> Expression: return _binary_op("mapFromArrays", key,

[GitHub] [flink] liuyongvs commented on a diff in pull request #22745: [FLINK-31691][table] Add built-in MAP_FROM_ENTRIES function.

liuyongvs commented on code in PR #22745: URL: https://github.com/apache/flink/pull/22745#discussion_r1251435754 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/Expressions.java: ## @@ -553,6 +553,23 @@ public static ApiExpression

[GitHub] [flink] liuyongvs commented on a diff in pull request #22745: [FLINK-31691][table] Add built-in MAP_FROM_ENTRIES function.

liuyongvs commented on code in PR #22745: URL: https://github.com/apache/flink/pull/22745#discussion_r1248456341 ## docs/data/sql_functions.yml: ## @@ -658,6 +658,9 @@ collection: - sql: MAP_FROM_ARRAYS(array_of_keys, array_of_values) table: mapFromArrays(array_of_keys,