关于 generic type 的问题

[a511955993 <a5...@163.com>]

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

在flink-core中存在ListSerializer，可是不知道要如何使用。

Re: 关于 generic type 的问题

[Jingsong Li <ji...@gmail.com>]

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 <a5...@163.com> wrote:

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



-- 
Best, Jingsong Lee