flink
文章23 | 阅读 12042 | 点赞0
来源:https://www.kancloud.cn/zhangpn/flink
stream.startNewChain()
开启新的链,相当于开启了redistribution。
stream.disableChaining()
从stream算子开始到结束禁用Chain,单独划出来,将不会合并链。
内容来源于网络,如有侵权,请联系作者删除!