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

    }

}


Reply via email to