flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jingsong Li <jingsongl...@gmail.com>
Subject Re: 关于 generic type 的问题
Date Wed, 06 May 2020 02:21:09 GMT
Hi,

因为List是有泛型来指定field的具体类型的,所以flink在以前没有能自动推断出来。

看起来只能用Types.POJO来自己构造PojoTypeInfo了。你可以用以下方式来指定type
info:

@TypeInfo(your type info factory)
class pojo{
String name;
List<String> someList;
}

Best,
Jingsong Lee


On Thu, Apr 30, 2020 at 9:15 PM a511955993 <a511955993@163.com> wrote:

> hi,咨询一个问题,我们在定义实体的时候,如果属性中使用了List,就会被识别成
generic
> type。这个要如何设置,才可以识别成为Flink可序列化的类,而不是使用kyro。
> class pojo{
> String name;
> List<String> someList;
> }
>
> 在flink-core中存在ListSerializer,可是不知道要如何使用。



-- 
Best, Jingsong Lee
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message