Apache Flink 分区算子Shuffle剖析

Apache Flink 分区算子Shuffle剖析

1.概述1.1定义Shuffle是Apache Flink中的一个分区算子,用于将数据流进行随机分区。它可以将数据流中的每个元素随机地分配到下游算子的一个分区中,从而实现数据的随机分布。1.2Shuffle算子的实现流程在Flink中,Sh

8小时前10