- 链接地址:https://blog.csdn.net/andyonlines/article/details/107826870
- 链接标题:五 Flink DataStream API_connect keyby-CSDN博客
- 所属网站:blog.csdn.net
- 被收藏次数:4102
文章浏览阅读328次。文章目录1.map2.filter3 flatmap函数4 keyby4.1 滚动聚合1.map实现Map操作,有三种方法.map操作是UDF(一进一出)1.第一种是和spark的map类似,直接在map算子中传入匿名函数2.其实map算子接收的是一个实现MapFunction接口的类,我们可以传入一个匿名类3.可以创建一个实现MapFunction接口的类.package org.example.puapiimport org.apache.flink.api.common.functio_connect keyby
版权声明:本文发布于特牛网址导航 内容均来源于互联网 如有侵权联系删除