1. 数据分发策略数据的分区策略决定了数据会分发到下游算子的那个分区,在 Flink 中有八种不同的分区策略,也称为分区器。
1.1 ChannelSelectorChannelSelector 是一个接口,它的核心功能是为输入的数据选择
2020-06-15