可以直接返回Map类型呀，比如：
public class String2Map extends ScalarFunction {
public Map<String, String> eval(String param) throws Exception {
Map<String, String> map = new HashMap<>();
// ...
return map;
}
@Override
public TypeInformation<?> getResultType(Class<?>[] signature) {
return Types.MAP(Types.STRING, Types.STRING);
}
}
zilong xiao <acidzz...@gmail.com> 于2020年8月6日周四 上午10:24写道：
>
> 感谢benchao大佬回答，对于Java用户而言，Map容器用的也比较多，目前有用户需要从json字符串中取对应key的值，目前的做法是提供了一个getValueFromJson的UDF，每次要取值时都要将json反序列化成Map然后get(key)，有什么方法可以使得UDF直接返回Map类型吗？这样就可以避免每次都去反序列化然后取值
>
> Benchao Li <libenc...@apache.org> 于2020年8月5日周三 下午11:49写道：
>
> > Hi zilong，
> >
> > SQL里面的ARRAY类型，对应的legacy
> type，应该是Types.PRIMITIVE_ARRAY或者Types.OBJECT_ARRAY，
> > 其他类型的type information会被当做any类型来处理。
> > 这里应该跟泛型没有关系，就是在实现的时候并没有考虑将Types.LIST(Types.STRING)当做SQL里面的ARRAY类型。
> > 支持List作为ARRAY的数据，应该要在1.12才能支持[1]。
> >
> > [1] https://issues.apache.org/jira/browse/FLINK-18417
> >
> > zilong xiao <acidzz...@gmail.com> 于2020年8月3日周一 下午8:23写道：
> >
> > > 不行的，试过了，遍历map把里面的entity全部toString都不行，应该是Java泛型机制的原因，不知道社区大佬怎么看待这个问题
> > >
> > > godfrey he <godfre...@gmail.com> 于2020年8月3日周一 下午7:50写道：
> > >
> > > > 你把Map<Object, Object>换为Map<String, String>试试
> > > >
> > > > zilong xiao <acidzz...@gmail.com> 于2020年8月3日周一 下午4:56写道：
> > > >
> > > > > 目前转List可以用数组代替，Map貌似没法成功运行
> > > > >
> > > > > zilong xiao <acidzz...@gmail.com> 于2020年8月3日周一 上午10:43写道：
> > > > >
> > > > > > 最近在写Flink SQL处理数据的时候发现Flink自带的function不太能满足使用，像很常见的Json2Array
> > > > > > Json2Map貌似官方都没有实现，所以需要自定义函数来实现，然后我自己尝试用Jackson来实现时发现在语法检查时总是会报
> > `Type
> > > is
> > > > > not
> > > > > > supported:
> > > > > >
> > > > >
> > > >
> > >
> >
> ANY`，个人猜想这个是不是和Java泛型的特性有关，由于Java是假泛型，最终泛型会被擦除编程Object才会引发这个异常呢？想到Flink本身也有一个字符串转容器的函数
> > > > > >
> > STR_TO_MAP，看了下该函数实现是用Scala编写，不确定该异常是否真是由泛型引起，如果是，如果想要Java写Json2Array
> > > > > Json2Map
> > > > > > udf应该怎么操作呢？求前辈指导
> > > > > >
> > > > > > udfd代码如下：
> > > > > >
> > > > > > public class Json2List extends ScalarFunction {
> > > > > >
> > > > > > private static final Logger LOG =
> > > > > LoggerFactory.getLogger(Json2List.class);
> > > > > >
> > > > > > private static final ObjectMapper OBJECT_MAPPER = new
> > > ObjectMapper()
> > > > > > .configure(JsonParser.Feature.ALLOW_SINGLE_QUOTES, true)
> > > > > > .configure(JsonParser.Feature.ALLOW_UNQUOTED_CONTROL_CHARS,
> > > > true) ;
> > > > > >
> > > > > > public Json2List(){}
> > > > > >
> > > > > > public List<String> eval(String param) {
> > > > > > List<String> result = new ArrayList<>();
> > > > > > try {
> > > > > > List<Map<Object, Object>> list =
> > > > OBJECT_MAPPER.readValue(param,
> > > > > List.class);
> > > > > > for(Map<Object, Object> map : list){
> > > > > > result.add(OBJECT_MAPPER.writeValueAsString(map));
> > > > > > }
> > > > > > return result;
> > > > > > } catch (JsonProcessingException e){
> > > > > > LOG.error("failed to convert json to array, param is:
> {}",
> > > > > param, e);
> > > > > > }
> > > > > > return result;
> > > > > > }
> > > > > >
> > > > > >
> > > > > > @Override
> > > > > > public TypeInformation<List<String>> getResultType(Class<?>[]
> > > > > signature) {
> > > > > > return Types.LIST(Types.STRING);
> > > > > > }
> > > > > >
> > > > > > }
> > > > > >
> > > > > >
> > > > >
> > > >
> > >
> >
> >
> > --
> >
> > Best,
> > Benchao Li
> >
>
--
Best,
Benchao Li
