hanyuzheng7 commented on code in PR #22951:
URL: https://github.com/apache/flink/pull/22951#discussion_r1489798277
##########
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java:
##########
@@ -231,6 +232,21 @@ ANY, and(logical(LogicalTypeRoot.BOOLEAN), LITERAL)
"org.apache.flink.table.runtime.functions.scalar.ArrayContainsFunction")
.build();
+ public static final BuiltInFunctionDefinition ARRAY_SORT =
+ BuiltInFunctionDefinition.newBuilder()
+ .name("ARRAY_SORT")
+ .kind(SCALAR)
+ .inputTypeStrategy(
+ or(
+ sequence(new
ArrayComparableElementArgumentTypeStrategy()),
+ sequence(
+ new
ArrayComparableElementArgumentTypeStrategy(),
+ logical(LogicalTypeRoot.BOOLEAN))))
Review Comment:
The updated function signature is now `ARRAY_SORT(<array>,[,
<sort_ascending>[, <nulls_first>]])`, where both sort_ascending and nulls_first
parameters are optional, allowing for more flexibility in array sorting
behavior.
The description like this
`The function sorts an array, defaulting to ascending order with NULLs at
the start when only the array is input. Specifying ascending_order as true
orders the array in ascending with NULLs first, and setting it to false orders
it in descending with NULLs last. Independently, null_first as true moves NULLs
to the beginning, and as false to the end, irrespective of the sorting order.
The function returns null if any input is null.`
@MartijnVisser @dawidwys
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
