幾種分區(qū)策略

custom partitioning

手動(dòng)分區(qū)，手動(dòng)設(shè)置分區(qū)和指定value作為分區(qū)

dataStream.partitionCustom(partitioner, "someKey");

shuffle

隨機(jī)分區(qū)

dataStream.shuffle();

rebalance

round-robin，負(fù)載均衡，均勻分布

dataStream.rebalance();

rescaling

均勻分發(fā)到同一chain的下游

dataStream.rescale();

broadcasting

廣播到下游，每個(gè)算子都會(huì)得到所有的值

dataStream.broadcast();

總結(jié)

以上是生活随笔為你收集整理的flink physical partition的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。