Flink slotSharingGroup disableChain startNewChain 用法案例

 使用slot分组 或者 disableChaining(),我们可以将算子的依赖链给隔离或者分开,这样可以针对不同的需求进行不同的优化。   package application; import com.alibaba.fastjson.JSONObject; import operator.*; import org.apache.commons.lang.StringUtils; im
相关文章
相关标签/搜索