org.apache.flink.types.Row类型如何使用keyBy

来源：7-14 Window Functions之ProcessWindowFunction的Java实现

吼吼16

2020-07-06

老师请教一下，每行元素都是org.apache.flink.types.Row类型，如何使用keyBy呢，直接填入pos会报错

org.apache.flink.api.common.InvalidProgramException: Specifying keys via field positions is only valid for tuple data types. Type: GenericType<org.apache.flink.types.Row>

写回答

1回答

Michael_PK

2020-07-06

代码贴下看看

新一代大数据计算引擎 Flink从入门到实战

入行或转型大数据新姿势，多语言系统化讲解，极速入门Flink

969 学习 · 296 问题

查看课程

相似问题

groupBy和keyBy的key选择器不一样吗？

回答 1

flink只有在sum操作之前需要先根据tuple指定的key进行分组么？

回答 1

老师请问用flink本地跑没问题，在集群上跑就报空指针，加了判断还是有，详细报错如下：

回答 2

序列化

回答 1

Socket断开时基于DataStream应用的failover如何处理?

回答 1

打开慕课网App查看更多内容