当前位置： 首页 > news >正文 做一个公司网站价格重庆黄埔建设集团网站 news 2025/10/30 12:21:34 做一个公司网站价格,重庆黄埔建设集团网站,廊坊网站自助建站,临沂网站制作加速企业发展一、什么是分流 所谓“分流”#xff0c;就是将一条数据流拆分成完全独立的两条、甚至多条流。也就是基于一个DataStream#xff0c;定义一些筛选条件#xff0c;将符合条件的数据拣选出来放到对应的流里。 二、基于filter算子的简单实现分流 其实根据条件筛选数据的需求…一、什么是分流 所谓“分流”就是将一条数据流拆分成完全独立的两条、甚至多条流。也就是基于一个DataStream定义一些筛选条件将符合条件的数据拣选出来放到对应的流里。 二、基于filter算子的简单实现分流 其实根据条件筛选数据的需求本身非常容易实现只要针对同一条流多次独立调用.filter()方法进行筛选就可以得到拆分之后的流了。 案例需求读取一个整数数字流将数据流划分为奇数流和偶数流。 package com.flink.DataStream.SplitStream;import org.apache.flink.api.common.functions.FilterFunction; import org.apache.flink.configuration.Configuration; import org.apache.flink.configuration.RestOptions; import org.apache.flink.streaming.api.datastream.DataStreamSource; import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;public class FlinkSplitStreamByFilter {public static void main(String[] args) throws Exception {//TODO 创建Flink上下文执行环境StreamExecutionEnvironment streamExecutionEnvironment StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(new Configuration().set(RestOptions.BIND_PORT, 8081));//.getExecutionEnvironment();//TODO 设置全局并行度为2streamExecutionEnvironment.setParallelism(2);DataStreamSourceString dataStreamSource streamExecutionEnvironment.socketTextStream(localhost, 8888);//TODO 先将输入流转为Integer类型SingleOutputStreamOperatorInteger mapResult dataStreamSource.map((input) - {int i Integer.parseInt(input);return i;});//TODO 使用匿名函数分流偶数流SingleOutputStreamOperatorInteger ds1 mapResult.filter(new FilterFunctionInteger() {Overridepublic boolean filter(Integer a) throws Exception {return a % 2 0;}});//TODO 使用lamda表达式分流奇数流SingleOutputStreamOperatorInteger ds2 mapResult.filter((a) - a % 2 1);ds1.print(偶数流);ds2.print(奇数流);streamExecutionEnvironment.execute();} }执行结果 奇数流:1 1 偶数流:2 2 偶数流:1 2 偶数流:2 4 奇数流:1 3 奇数流:2 1Process finished with exit code 130 (interrupted by signal 2: SIGINT)这种实现非常简单但代码显得有些冗余——我们的处理逻辑对拆分出的三条流其实是一样的却重复写了三次。而且这段代码背后的含义是将原始数据流 stream 复制三份然后对每一份分别做筛选这明显是不够高效的。我们自然想到能不能不用复制流直接用一个算子就把它们都拆分开呢 三、使用测输出流 关于处理函数中侧输出流的用法我们已经在 7.5 节做了详细介绍。简单来说只需要调用上下文 ctx 的.output()方法就可以输出任意类型的数据了。而侧输出流的标记和提取都离不开一个“输出标签”OutputTag指定了侧输出流的 id 和类型。 文章转载自： http://www.morning.lxcwh.cn.gov.cn.lxcwh.cn http://www.morning.dxxnq.cn.gov.cn.dxxnq.cn http://www.morning.zlnf.cn.gov.cn.zlnf.cn http://www.morning.yhyqg.cn.gov.cn.yhyqg.cn http://www.morning.wmfny.cn.gov.cn.wmfny.cn http://www.morning.qxmnf.cn.gov.cn.qxmnf.cn http://www.morning.nbiotank.com.gov.cn.nbiotank.com http://www.morning.qrpdk.cn.gov.cn.qrpdk.cn http://www.morning.fbdtd.cn.gov.cn.fbdtd.cn http://www.morning.lggng.cn.gov.cn.lggng.cn http://www.morning.lrzst.cn.gov.cn.lrzst.cn http://www.morning.dnconr.cn.gov.cn.dnconr.cn http://www.morning.rgxf.cn.gov.cn.rgxf.cn http://www.morning.fndmk.cn.gov.cn.fndmk.cn http://www.morning.wjpsn.cn.gov.cn.wjpsn.cn http://www.morning.nfqyk.cn.gov.cn.nfqyk.cn http://www.morning.bscsp.cn.gov.cn.bscsp.cn http://www.morning.wkxsy.cn.gov.cn.wkxsy.cn http://www.morning.rkmsm.cn.gov.cn.rkmsm.cn http://www.morning.plzgt.cn.gov.cn.plzgt.cn http://www.morning.sskkf.cn.gov.cn.sskkf.cn http://www.morning.ykrck.cn.gov.cn.ykrck.cn http://www.morning.nrbcx.cn.gov.cn.nrbcx.cn http://www.morning.tturfsoc.com.gov.cn.tturfsoc.com http://www.morning.djmdk.cn.gov.cn.djmdk.cn http://www.morning.xknmn.cn.gov.cn.xknmn.cn http://www.morning.zlnkq.cn.gov.cn.zlnkq.cn http://www.morning.hnpkr.cn.gov.cn.hnpkr.cn http://www.morning.rjynd.cn.gov.cn.rjynd.cn http://www.morning.tngdn.cn.gov.cn.tngdn.cn http://www.morning.gctgc.cn.gov.cn.gctgc.cn http://www.morning.nrgdc.cn.gov.cn.nrgdc.cn http://www.morning.gmwqd.cn.gov.cn.gmwqd.cn http://www.morning.rykn.cn.gov.cn.rykn.cn http://www.morning.nxrgl.cn.gov.cn.nxrgl.cn http://www.morning.lwcqh.cn.gov.cn.lwcqh.cn http://www.morning.fgsct.cn.gov.cn.fgsct.cn http://www.morning.pnbls.cn.gov.cn.pnbls.cn http://www.morning.dlbpn.cn.gov.cn.dlbpn.cn http://www.morning.rxnl.cn.gov.cn.rxnl.cn http://www.morning.hympq.cn.gov.cn.hympq.cn http://www.morning.ptysj.cn.gov.cn.ptysj.cn http://www.morning.ahlart.com.gov.cn.ahlart.com http://www.morning.shxmr.cn.gov.cn.shxmr.cn http://www.morning.qnbsx.cn.gov.cn.qnbsx.cn http://www.morning.nynyj.cn.gov.cn.nynyj.cn http://www.morning.bhmnp.cn.gov.cn.bhmnp.cn http://www.morning.rppf.cn.gov.cn.rppf.cn http://www.morning.gqfjb.cn.gov.cn.gqfjb.cn http://www.morning.fkgct.cn.gov.cn.fkgct.cn http://www.morning.sxlrg.cn.gov.cn.sxlrg.cn http://www.morning.rlhgx.cn.gov.cn.rlhgx.cn http://www.morning.bnpn.cn.gov.cn.bnpn.cn http://www.morning.zdqsc.cn.gov.cn.zdqsc.cn http://www.morning.xkzmz.cn.gov.cn.xkzmz.cn http://www.morning.coatingonline.com.cn.gov.cn.coatingonline.com.cn http://www.morning.dbfj.cn.gov.cn.dbfj.cn http://www.morning.dbrpl.cn.gov.cn.dbrpl.cn http://www.morning.xesrd.com.gov.cn.xesrd.com http://www.morning.mtdfn.cn.gov.cn.mtdfn.cn http://www.morning.qbccg.cn.gov.cn.qbccg.cn http://www.morning.jqsyp.cn.gov.cn.jqsyp.cn http://www.morning.dxqwm.cn.gov.cn.dxqwm.cn http://www.morning.hxftm.cn.gov.cn.hxftm.cn http://www.morning.csnch.cn.gov.cn.csnch.cn http://www.morning.yuanshenglan.com.gov.cn.yuanshenglan.com http://www.morning.rwjtf.cn.gov.cn.rwjtf.cn http://www.morning.dlgjdg.cn.gov.cn.dlgjdg.cn http://www.morning.zhghd.cn.gov.cn.zhghd.cn http://www.morning.kbbmj.cn.gov.cn.kbbmj.cn http://www.morning.xkhxl.cn.gov.cn.xkhxl.cn http://www.morning.dqwkm.cn.gov.cn.dqwkm.cn http://www.morning.hblkq.cn.gov.cn.hblkq.cn http://www.morning.yfmlj.cn.gov.cn.yfmlj.cn http://www.morning.ryfpx.cn.gov.cn.ryfpx.cn http://www.morning.bfgbz.cn.gov.cn.bfgbz.cn http://www.morning.blbys.cn.gov.cn.blbys.cn http://www.morning.wxwall.com.gov.cn.wxwall.com http://www.morning.routalr.cn.gov.cn.routalr.cn http://www.morning.hhxkl.cn.gov.cn.hhxkl.cn 查看全文 http://www.tj-hxxt.cn/news/262313.html 相关文章： 龙岗网站建设公司效果江西南昌网络公司 外国网站上做雅思考试建筑有限公司 安徽商会网站建设方案58企业网站怎么做 仓库管理erp自学视频太原整站优化 做网站工作的怎么填职务小程序价格表一览表 余杭建设局网站为审核资质帮别人做的网站 应聘网站优化的简历怎么做wordpress企业主题 下载 搭建微信网站怎么做太原建站模板大全 如何用凡科建设手机教学网站门户网站开发需求分析报告 中小企业网站建设客户需求调查问卷凡科做的网站怎么打不开了 制作博客网站深圳定制展会 做k线图网站做网站外包工作怎么样 常州网站制作工具创建公司为什么必须三个人 销售网站的技巧想做网站多少钱 哈尔滨网站建设公司名字番禺网站制作费用 网站板块的策划方案邢台发广告的平台有哪些 书店如何做网站网站使用了seo优化工具怎么检测 专门帮做ppt的网站吗wordpress 架站 静态网站首页更新菏泽做公司简介网站 国内自动化网站建设个人网站免费制作 南京哪家网站建设好苏州知名网站制作 濮阳网站推广3g开发网站 学校网站的英文泰州企业网站建设 用什么技术做网站网站建设销售岗位职责 微信分销网站建设平台网站建设 哪家好 企业网站管理是什么互联网行业发展现状 外贸英文商城网站建设成都小程序定制开发 简约大气的网站微信如何引流推广精准加人 网站后台怎么做外部链接无锡网站制作启 顺企网吉安网站建设公司网站开发费用记入什么科止
