我看了现在的 flink 1.11 的 keyBy 的代码,是使用的KeySelector<T, K> 
key,但每次只能返回一个字段,不支持返回多个字段,也就说明了一次只能按一个字段去分组(PS: test.keyBy(t -> 
t.f0)),如果我想按多个字段进行分组的话该怎么操作呢?

-----邮件原件-----
发件人: guanxianchun <[email protected]> 
发送时间: 2020年11月19日 20:53
收件人: [email protected]
主题: Re: Flink 1.10 和 Flink 1.11 中 keyBy 算子聚合多个字段的问题

flink-1.11使用KeySelector<IN, KEY>



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复