GlobalStreamExchangeMode 这几种交换模式的不同和使用场景是什么?哪些适合流式作业,哪些适合批式作业? Flink Remote Shuffle Service的推出是不是意味着可以在生产环境使用Flink处理批式作业?谢谢!
package org.apache.flink.streaming.api.graph; import org.apache.flink.annotation.Internal; @Internal public enum GlobalStreamExchangeMode { ALL_EDGES_BLOCKING, FORWARD_EDGES_PIPELINED, POINTWISE_EDGES_PIPELINED, ALL_EDGES_PIPELINED, ALL_EDGES_PIPELINED_APPROXIMATE; private GlobalStreamExchangeMode() { } }