Flink中如何实现自定义的分区策略？

　　1、自定义Partitioner： 实现Partitioner接口，定义数据分配到不同并行实例的逻辑。

　　2、应用分区策略： 在数据流转换操作中应用自定义的分区策略。

　　3、场景： 适用于标准的分区策略无法满足特定需求的情况。

很赞哦！

python编程网提示：转载请注明来源www.python66.com。
有宝贵意见可添加站长微信(底部)，获取技术资料请到公众号(底部)。同行交流请加群