liuyongvs commented on code in PR #22312:
URL: https://github.com/apache/flink/pull/22312#discussion_r1221171695
##########
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SpecificTypeStrategies.java:
##########
@@ -89,6 +95,49 @@ public final class SpecificTypeStrategies {
/** See {@link ToTimestampLtzTypeStrategy}. */
public static final TypeStrategy TO_TIMESTAMP_LTZ = new
ToTimestampLtzTypeStrategy();
+ /** Type strategy specific for {@link
BuiltInFunctionDefinitions#MAP_KEYS}. */
+ public static final TypeStrategy MAP_KEYS =
+ callContext ->
+ Optional.of(
+ DataTypes.ARRAY(
+ ((KeyValueDataType)
callContext.getArgumentDataTypes().get(0))
+ .getKeyDataType()));
+
+ /** Type strategy specific for {@link
BuiltInFunctionDefinitions#MAP_VALUES}. */
+ public static final TypeStrategy MAP_VALUES =
+ callContext ->
+ Optional.of(
+ DataTypes.ARRAY(
+ ((KeyValueDataType)
callContext.getArgumentDataTypes().get(0))
+ .getValueDataType()));
+
+ /** Type strategy specific for {@link
BuiltInFunctionDefinitions#MAP_ENTRIES}. */
+ public static final TypeStrategy MAP_ENTRIES =
+ callContext ->
+ Optional.of(
+ DataTypes.ARRAY(
+ DataTypes.ROW(
Review Comment:
added @luoyuxia
--
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]
