Apache Flink流分區器剖析

這篇文章介紹Flink的分區器，在流進行轉換操做後，Flink經過分區器來精確得控制數據流向。java StreamPartitioner StreamPartitioner是Flink流分區器的基類，它只定義了一個抽象方法：web public abstract StreamPartitioner<T> copy(); 但這個方法並非各個分區器之間互相區別的地方，定義不一樣的分區器的核心在於——

>>阅读原文<<