（1）返回字符串，自己拼接就可以。 （2）返回Tuple类型作为Key。 1.10到1.11相当于是去除了多key的辅助keyBy方法，本身内部就是组成tuple。原因不清楚。
sherlock zw <[email protected]> 于2020年11月20日周五 上午11:18写道： > 我看了现在的 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/ >
