Aggregate算子求最大值

更新时间:2023-06-18 09:47:06 阅读: 评论:0

Aggregate算⼦求最⼤值
彩色钥匙package comic.ding
import org.apache.flink.api.java.aggregation.Aggregations
脏内裤import org.apache.flink.api.scala.{AggregateDataSet, DataSet, ExecutionEnvironment}
一y
全屏壁纸import org.apache.flink.streaming.api.scala._
llection.mutable
object AggregateDemo {
def main(args: Array[String]): Unit = {
鲑鱼做法val env = ExecutionEnvironment
val data = new mutable.MutableList[(Int, String, Double)]
陈乔恩的电视剧
data.+=((1, "yuwen", 89.0))
data.+=((2, "shuxue", 92.2))
data.+=((3, "yuwen", 89.99))
// 构建数据源
val input: DataSet[(Int, String, Double)] = env.fromCollection(data)文明出行
val value: AggregateDataSet[(Int, String, Double)] = upBy(1).aggregate(Aggregations.MAX,2)
value.print()
}
}
注意:
1,Aggregate只能作⽤于元组上
2,使⽤aggregate,只能使⽤字段索引名或索引名称来进⾏分组 groupBy(0) ,否则会报以下错误:
Exception in thread "main" java.lang.UnsupportedOperationException: Aggregate does not support grouping with KeySelector functions, yet.
芹菜英语

本文发布于:2023-06-18 09:47:06,感谢您对本站的认可!

本文链接:https://www.wtabcd.cn/fanwen/fan/89/1043832.html

版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,我们将在24小时内删除。

标签:壁纸   鲑鱼   构建   只能   名称   全屏   做法
相关文章
留言与评论(共有 0 条评论)
   
验证码:
推荐文章
排行榜
Copyright ©2019-2022 Comsenz Inc.Powered by © 专利检索| 网站地图