Flink中Filter怎么用
小编给大家分享一下Flink中Filter怎么用,相信大部分人都还不怎么了解,因此分享这篇文章给大家参考一下,希望大家阅读完这篇文章后大有收获,下面让我们一起去了解一下吧!
十余年的会同网站建设经验,针对设计、前端、开发、售后、文案、推广等六对一服务,响应快,48小时及时工作处理。营销型网站建设的优势是能够根据用户设备显示端的尺寸不同,自动调整会同建站的显示方式,使网站能够适用不同显示终端,在浏览器中调整网站的宽度,无论在任何一种浏览器上浏览网站,都能展现优雅布局与设计,从而大程度地提升浏览体验。创新互联建站从事“会同网站设计”,“会同网站推广”以来,每个客户项目都认真落实执行。
Filter算子:对数据流进行过滤,只返回为true的数据
示例环境
java.version: 1.8.x flink.version: 1.11.1
示例数据源 (项目码云下载)
Flink 系例 之 搭建开发环境与数据
Fliter.java
import com.flink.examples.DataSource; import org.apache.flink.api.common.functions.FilterFunction; import org.apache.flink.api.java.tuple.Tuple3; import org.apache.flink.streaming.api.datastream.DataStream; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import java.util.List; /** * @Description Filter算子:对数据流进行过滤,只返回为true的数据 */ public class Filter { /** * 遍历集合,只打印性别为男性的记录 * @param args * @throws Exception */ public static void main(String[] args) throws Exception { final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); List> tuple3List = DataSource.getTuple3ToList(); DataStream > dataStream = env.fromCollection(tuple3List).filter(new FilterFunction >() { @Override public boolean filter(Tuple3 tuple3) throws Exception { //性别(1男,2女) return tuple3.f1.equals("man"); } }); dataStream.print(); env.execute("flink Filter job"); } }
打印结果
4> (吴八,man,30) 3> (张三,man,20) 1> (王五,man,29)
以上是“Flink中Filter怎么用”这篇文章的所有内容,感谢各位的阅读!相信大家都有了一定的了解,希望分享的内容对大家有所帮助,如果还想学习更多知识,欢迎关注创新互联行业资讯频道!
文章名称:Flink中Filter怎么用
本文路径:http://scyanting.com/article/jccche.html