Hey Steve, You should be able to do via the bridgedTo parameter. You can additionally specify a serializer you want to use via rawSerializer parameter:
@FunctionHint( input = { @DataTypeHint(value = "RAW", bridgedTo = Map.class[, rawSerializer = ... ]), @DataTypeHint("STRING")}, output = @DataTypeHint("STRING") ) public static String eval(final Object map, final String key) Best, Dawid On 26/10/2020 16:10, Steve Whelan wrote: > 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
signature.asc
Description: OpenPGP digital signature