大数据_Flink_Java版_数据处理_流处理API_Flink中的数据重分区操作_keyBy_rebalance_gloable_shuffle---Flink工作笔记0037

捌柒陆壹

 关注

阅读 58

2022-03-11

然后我们再来看,可以看到对于分区,之前我们已经有keyBy用了,我们说keyBy

是用hash值来分区的对吧.

然后我们再来看,这个broadcast这个是广播的方式

广播的方式就是把数据进行广播出去,然后,所有的分区都能收到广播的数据.

 

然后看到这里有个shuffle这个方式,是进行洗牌的方式,其实就是把数据进行打乱操作,顺序打乱,

然后发到不同的分区上.

 

相关推荐

大数据_Flink_Java版_数据处理_流处理API_Flink支持的数据类型---Flink工作笔记0035

扒皮狼 42 0 0

大数据_Flink_Java版_数据处理_流处理API_Sink操作_Kafka---Flink工作笔记0038

惠特曼 60 0 0

大数据_Flink_Java版_数据处理_流处理API_Transform(4)_分流---Flink工作笔记0032

柠檬的那个酸_2333 69 0 0

大数据_Flink_Java版_数据处理_流处理API_Transform(5)_union合流---Flink工作笔记0034

霍华德 64 0 0

大数据_Flink_Java版_数据处理_Window_API_基本概念---Flink工作笔记0042

登高且赋 42 0 0

大数据_Flink_Java版_数据处理_Watermark(7)_的设定原则---Flink工作笔记0056

小月亮06 103 0 0

大数据_Flink_Java版_数据处理_Window_API(3)_计数窗口测试---Flink工作笔记0047

J简文 45 0 0

大数据_Flink_Java版_数据处理_Watermark_概念和原理---Flink工作笔记0052

追梦人的自留地 83 0 0

大数据_Flink_Java版_数据处理_Watermark_特点和行为---Flink工作笔记0053

niboac 61 0 0

大数据_Flink_数据处理_案例WorldCount_流处理版---Flink工作笔记0009

新鲜小饼干 78 0 0

精彩评论（0）

0 0 举报