flink physical partition
几种分区策略
custom partitioning
手动分区，手动设置分区和指定value作为分区
dataStream.partitionCustom(partitioner, "someKey");
shuffle
随机分区
dataStream.shuffle();
rebalance
round-robin，负载均衡，均匀分布
dataStream.rebalance();
rescaling
均匀分发到同一chain的下游
dataStream.rescale();
broadcasting
广播到下游，每个算子都会得到所有的值
dataStream.broadcast();
本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！