搜索结果
查询Tags标签： liucf，共有 4条记录-
09-flink-1.10.1- flink的编程风格ＵＤＦ函数
１ 实现ＵＤＦ函数 可以更细粒度的对流进行控制 ｆｌｉｎｋ暴露了所有ｕｄｆ函数的接口，实现方式是接口或者抽象类比如MapFunction，FilterFunction，ProcessFunction等等。我们很容易在flink的算子里发现所有的算子都有两份重载的函数，①一个可以直接传入一个lamda表达…
2021/9/13 1:05:06 人评论 次浏览 -
09-flink-1.10.1- flink的编程风格ＵＤＦ函数
１ 实现ＵＤＦ函数 可以更细粒度的对流进行控制 ｆｌｉｎｋ暴露了所有ｕｄｆ函数的接口，实现方式是接口或者抽象类比如MapFunction，FilterFunction，ProcessFunction等等。我们很容易在flink的算子里发现所有的算子都有两份重载的函数，①一个可以直接传入一个lamda表达…
2021/9/13 1:05:06 人评论 次浏览 -
06-flink-1.10.1-flink source api
1 flink 从集合中读取数据 1.1 代码 package com.study.liucf.bounded.api.sourceimport org.apache.flink.streaming.api.scala._/*** @Author liucf* @Date 2021/9/5*/case class SensorReding(id:String,timeStamp:Long,temperature:Double) object CollectionSource {…
2021/9/5 23:09:30 人评论 次浏览 -
06-flink-1.10.1-flink source api
1 flink 从集合中读取数据 1.1 代码 package com.study.liucf.bounded.api.sourceimport org.apache.flink.streaming.api.scala._/*** @Author liucf* @Date 2021/9/5*/case class SensorReding(id:String,timeStamp:Long,temperature:Double) object CollectionSource {…
2021/9/5 23:09:30 人评论 次浏览
