Apache Flink 中文用户邮件列表
Search
everywhere
only in this topic
Advanced Search
广播流传输自定义对象无效
Classic
List
Threaded
♦
♦
Locked
1 message
牙牙
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。
还请哪位大佬,指点迷津!
Free forum by Nabble
Edit this page