Flink slotSharingGroup disableChain startNewChain 用法案例

 使用slot分組 或者 disableChaining(),我們可以將算子的依賴鏈給隔離或者分開,這樣可以針對不同的需求進行不同的優化。   package application; import com.alibaba.fastjson.JSONObject; import operator.*; import org.apache.commons.lang.StringUtils; im
相關文章
相關標籤/搜索