幾種分區(qū)策略

custom partitioning

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

dataStream.partitionCustom(partitioner, "someKey");

shuffle

隨機分區(qū)

dataStream.shuffle();

rebalance

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

dataStream.rebalance();

rescaling

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

dataStream.rescale();

broadcasting

廣播到下游，每個算子都會得到所有的值

dataStream.broadcast();

總結(jié)

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

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