Flink 1.10 和 Flink 1.11 中 keyBy 算子聚合多个字段的问题
在 Flink 1.10.x 中的 keyBy 算子可以同时按多个字段分组，比如 map.keyBy(0,1)，但在 1.11.x 版本中这种方式被弃用了，看了下源码好像不支持按多字段分组了？还是有别的其他形式？
如果我想按多个字段分组的话需要怎么操作？*来自志愿者整理的flink邮件归档
展开
收起
1
条回答
写回答
写回答
-
（1）返回字符串，自己拼接就可以。
（2）返回Tuple类型作为Key。
1.10到1.11相当于是去除了多key的辅助keyBy方法，本身内部就是组成tuple。原因不清楚。
*来自志愿者整理的flink邮件归档
2021-12-06 11:23:43赞同 展开评论 打赏
问答分类：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
