Flink startNewChain和disableChaining

x33g5p2x  于2021-03-14 发布在 Flink  
字(0.1k)|赞(0)|评价(0)|浏览(1920)
stream.startNewChain()

开启新的链,相当于开启了redistribution。

stream.disableChaining()

从stream算子开始到结束禁用Chain,单独划出来,将不会合并链。

相关文章