Hi, I have a column of type *RAW('java.util.Map', ?)* that I want to pass to a scalar function UDF. I'm using DataTypeHints but hitting an exception. What would be the proper DataTypeHint and data type param to achieve this?
@FunctionHint( input = {@DataTypeHint("RAW"), @DataTypeHint("STRING")}, output = @DataTypeHint("STRING") ) public static String eval(final Object map, final String key) { // business logic } *Exception:* Caused by: org.apache.flink.table.api.ValidationException: Invalid input arguments. Expected signatures are: MAP_VALUE(RAW('java.lang.Object', '...'), STRING) at org.apache.flink.table.types.inference.TypeInferenceUtil.createInvalidInputException(TypeInferenceUtil.java:190) at org.apache.flink.table.planner.functions.inference.TypeInferenceOperandChecker.checkOperandTypesOrError(TypeInferenceOperandChecker.java:131) at org.apache.flink.table.planner.functions.inference.TypeInferenceOperandChecker.checkOperandTypes(TypeInferenceOperandChecker.java:89) ... 50 more Caused by: org.apache.flink.table.api.ValidationException: Invalid argument type at position 0. Data type RAW('java.lang.Object', '...') expected but RAW('java.util.Map', ?) passed. at org.apache.flink.table.types.inference.TypeInferenceUtil.adaptArguments(TypeInferenceUtil.java:137) at org.apache.flink.table.types.inference.TypeInferenceUtil.adaptArguments(TypeInferenceUtil.java:102) at org.apache.flink.table.planner.functions.inference.TypeInferenceOperandChecker.checkOperandTypesOrError(TypeInferenceOperandChecker.java:126) ... 51 more Thank you, Steve