Apache Flink流分区器剖析

这篇文章介绍Flink的分区器，在流进行转换操做后，Flink经过分区器来精确得控制数据流向。java StreamPartitioner StreamPartitioner是Flink流分区器的基类，它只定义了一个抽象方法：web public abstract StreamPartitioner<T> copy(); 但这个方法并非各个分区器之间互相区别的地方，定义不一样的分区器的核心在于——

>>阅读原文<<