广播流传输自定义对象无效

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

广播流传输自定义对象无效

牙牙
hi,all
我这边遇到一个问题:
在定义广播流(non-keyed类型)的sourceFunction时,实际传输的流中元素数据为热加载的某个具体实现类A,此类A继承某个抽象类B,此抽象类B实现指定接口C,sourceFunction的泛型T指定为抽象类B类型。
现象:
下游算子的processFunction中,对于接收广播流数据的方法中收不到实现类A,实现类A实现序列化接口了,私有属性均有getter和setter。


还请哪位大佬,指点迷津!