flink keyBy多个字段
·
设置样例类：
case class BlackListWarning( userId: Long, adId: Long, msg: String)
1.复杂方式：
.keyBy("userId","adId")
之所以说复杂是因为返回类型是JavaTuple, 引用时需要转换
2.简便方式（推荐）
.keyBy( data => (data.userId, data.adId) )
魔乐社区（Modelers.cn) 是一个中立、公益的人工智能社区，提供人工智能工具、模型、数据的托管、展示与应用协同服务，为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作，由全产业链共同建设、共同运营、共同享有，推动国产AI生态繁荣发展。
更多推荐
1
0- 0
已为社区贡献3条内容
所有评论(0)