学习flink的keyBy函数,知道它就类似于Spark中的groupBy函数,但是对其返回值一直很疑惑
keyBy比如上面这个keyBy的返回值类型[(String,Int),String],主要就是搞不懂后面那个String是什么,后来询问了一些朋友得知:
(String,Int) => 是进行keyBy的数据类型
String => 是分流的key的数据类型
学习flink的keyBy函数,知道它就类似于Spark中的groupBy函数,但是对其返回值一直很疑惑
keyBy比如上面这个keyBy的返回值类型[(String,Int),String],主要就是搞不懂后面那个String是什么,后来询问了一些朋友得知:
(String,Int) => 是进行keyBy的数据类型
String => 是分流的key的数据类型
本文标题:Flink--keyBy分流
本文链接:https://www.haomeiwen.com/subject/dzmkdhtx.html
网友评论