问题:有什么办法可以让非广播流processElement在广播流processBroadcastElement读取完毕之后进行?
伪代码如下:
DataStream a //来自外部source
DataStream b //来自一个计算结果
a.connect(b.broadcast())
.process(
processElement(){
读取广播流 //报空指针异常
}
processBroadcastElement(){
初始化广播流
}
)
说明:报空指针异常原因:因为b的计算结果还未产生,所以广播流初始化未完成,读取就报错了!
这有个简单的流程图:
大佬们如何解决呀!!TnT。。。。
与恶龙缠斗过久,自身亦成为恶龙;凝视深渊过久,深渊将回以凝视…