使用定義用戶的分區(qū)器為每個元素選擇目標(biāo)任務(wù)。

效果

編寫Flink程序，接收socket的單詞數(shù)據(jù)，把每個字符串寫入到指定的分區(qū)中。

哈達(dá)普

火花

弗林克

示例代碼