当前位置: 首页 > news >正文

自己编辑网站怎么做吉安做网站优化

自己编辑网站怎么做,吉安做网站优化,服务平台名称大全,网站建设咨询公1.窗口聚合算子 在Flink中窗口聚合算子主要分类两类 滚动聚合算子(增量聚合)全窗口聚合算子(全量聚合) 1.1 滚动聚合算子 滚动聚合算子一次只处理一条数据,通过算子中的累加器对聚合结果进行更新,当窗口触发时再从累加器中取结果数据,一般使用算子如下: aggregatemaxmaxBy…1.窗口聚合算子 在Flink中窗口聚合算子主要分类两类 滚动聚合算子(增量聚合)全窗口聚合算子(全量聚合) 1.1 滚动聚合算子 滚动聚合算子一次只处理一条数据,通过算子中的累加器对聚合结果进行更新,当窗口触发时再从累加器中取结果数据,一般使用算子如下: aggregatemaxmaxByminminByreducesum 这里以aggregate算子作为示例 // ... // 每10s统计一次每个用户最近30s的行为条数 SingleOutputStreamOperatorTuple2String, Integer result watermarked.keyBy(userEvent - userEvent.getUId()).window(SlidingEventTimeWindows.of(Time.seconds(30), Time.seconds(10))) // 参数1:窗口长度 参数2:滑动步长即计算频率.aggregate(new AggregateFunctionUserEvent2, Tuple2String, Integer, Tuple2String, Integer() {// 这里给一个初始值Overridepublic Tuple2String, Integer createAccumulator() {return Tuple2.of(, 0);}// 在累加器中统计每个用户行为条数(来一条更新一次)Overridepublic Tuple2String, Integer add(UserEvent2 value, Tuple2String, Integer accumulator) {Tuple2String, Integer result Tuple2.of(value.getUId() - value.getName(), accumulator.f1 1);return result;}// 将累加器中的更新结果给到getResult方法,输出Overridepublic Tuple2String, Integer getResult(Tuple2String, Integer accumulator) {return accumulator;}// 这个方法在流式计算中可以不用实现,在上下游数据进行合并时需要用到,以spark为例,上有map和下游reduce的计算结果需要合并时需要实现这个方法Overridepublic Tuple2String, Integer merge(Tuple2String, Integer a, Tuple2String, Integer b) {Tuple2String, Integer merged Tuple2.of(a.f0, a.f1 b.f1);return merged;}}); // ...只展示部分代码,冗余代码已省略. 图解如下: 1.2 全窗口聚合算子 全窗口聚合算子会将数据记录在状态容器中,当窗口触发时会将整个窗口中的数据交给聚合函数,根据具体逻辑将这些数据进行计算,常用算子如下: applyprocess 这里以apply算子为例 // ... // 每10s统计一次最近30s每个用户行为发生事件最大两条数据 SingleOutputStreamOperatorUserEvent2 userEventTimeTop2 keyedStream.window(SlidingEventTimeWindows.of(Time.seconds(30), Time.seconds(10)))// 泛型1: 数据数据类型 泛型2: 输出数据类型 泛型3: key类型 泛型4: 窗口类型.apply(new WindowFunctionUserEvent2, UserEvent2, String, TimeWindow() {/***Param s 本次传入的key*Param window 本次传入窗口的各种元信息*Param input 本次输入的所有数据*Param out 输出数据**/Overridepublic void apply(String s, TimeWindow window, IterableUserEvent2 input, CollectorUserEvent2 out) throws Exception {// 创建集合接收迭代器中的数据ArrayListUserEvent2 userEvent2List new ArrayList();// 遍历迭代器,也就是输入数据for (UserEvent2 userEvent2 : input) {// 将数据添加到集合中userEvent2List.add(userEvent2);}// 将集合中的数据根据用户行为发生事件进行排序Collections.sort(userEvent2List, new ComparatorUserEvent2() {Overridepublic int compare(UserEvent2 o1, UserEvent2 o2) {// 倒序排序return Integer.parseInt(o2.getTime()) - Integer.parseInt(o1.getTime());}});// 将每个用户行为发生时间最大的两条数据输出for (int i 0; i Math.min(userEvent2List.size(), 2); i) {out.collect(userEvent2List.get(i));}}}); // ...只展示部分代码,冗余代码已省略. 图解如下:
http://www.w-s-a.com/news/258399/

相关文章:

  • 网站建设主体设计要求微信公众号缴费
  • 网站建设的税率WordPress多用户建站
  • 专业门户网站的规划与建设网络培训
  • 东莞汽车总站停止营业crm管理系统在线使用
  • 深圳网站建设公司哪个网络优化是做什么的
  • 大连地区做网站自己怎么做电影网站
  • 成都APP,微网站开发手机要访问国外网站如何做
  • 网站app建设用discuz做的手机网站
  • vs 2008网站做安装包公众号登录超时
  • 银川做网站推广wordpress dux会员中心
  • 双辽做网站wordpress怎么写html代码
  • 建站公司哪家好 知道万维科技西安都有哪些公司
  • 设计网站官网入口佛山 品牌设计
  • 专用网站建设wordpress mega
  • 网站建设与优化推广方案内容网站整站下载带数据库后台的方法
  • 做网站PAAS系统外链是什么意思
  • 网页设计专业设计课程googleseo排名公司
  • 网站百度百科那些免费网站可以做国外贸易
  • 做视频的网站有哪些南京计算机培训机构哪个最好
  • ppt做视频 模板下载网站商业街网站建设方案
  • 佛山网站定制开发星光影视园网站建设案例
  • wordpress子站点商务网页设计与制作微课版答案
  • 山东省住房城乡和建设厅网站软件开发主要几个步骤
  • 可以接项目做的网站网站源码php
  • 杭州广众建设工程有限公司网站网页游戏人气排行榜
  • 上海网站开发建设最简单的网站代码
  • 东莞做网站建设免费网站建设案例
  • 莱州建设局网站wordpress的主题下载地址
  • 二级网站域名长沙企业关键词优化服务质量
  • 在家有电脑怎么做网站wordpress 入门主题