詳解Flink中Forward Partitioner的使用方法,助力流式計(jì)算高效運(yùn)行
發(fā)送到下游對(duì)應(yīng)的第一個(gè)任務(wù),保證上游算子數(shù)量度一致,即下游算子與下游算子是1:1的關(guān)系?
源碼解讀

圖解

在上下游的算子沒(méi)有指定分區(qū)器的情況下,如果上下游的算子精度一致,則使用ForwardPartitioner,否則使用RebalancePartitioner,對(duì)于ForwardPartitioner,必須保證上下游的算子精度一致,否則會(huì)引發(fā)異常
效果
編寫(xiě)Flink程序,接收socket的單詞數(shù)據(jù),把每個(gè)字符串廣播到每個(gè)分區(qū)。
示例代碼
