使用定义用户的分区器为每个元素选择目标任务。

效果

编写Flink程序，接收socket的单词数据，把每个字符串写入到指定的分区中。

哈达普

火花

弗林克

示例代码