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() {
}
}
