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

在哪里可以免费做个人网站免费法律咨询24小时在线

在哪里可以免费做个人网站,免费法律咨询24小时在线,南京制作网站公司网站,域名注册地址查询map map是大家非常熟悉的大数据操作算子#xff0c;主要用于将数据流中的数据进行转换#xff0c;形成新的数据流。简单来说#xff0c;就是一个“一一映射”#xff0c;消费一个元素就产出一个元素。 我们只需要基于DataStream调用map()方法就可以进行转换处理。方法需要…map map是大家非常熟悉的大数据操作算子主要用于将数据流中的数据进行转换形成新的数据流。简单来说就是一个“一一映射”消费一个元素就产出一个元素。 我们只需要基于DataStream调用map()方法就可以进行转换处理。方法需要传入的参数是接口MapFunction的实现返回值类型还是DataStream不过泛型流中的元素类型可能改变。 public class TransMap {public static void main(String[] args) throws Exception {StreamExecutionEnvironment env StreamExecutionEnvironment.getExecutionEnvironment();DataStreamSourceWaterSensor stream env.fromElements(new WaterSensor(sensor_1, 1, 1),new WaterSensor(sensor_2, 2, 2));// 方式一传入匿名类实现MapFunctionstream.map(new MapFunctionWaterSensor, String() {Overridepublic String map(WaterSensor e) throws Exception {return e.id;}}).print();// 方式二传入MapFunction的实现类// stream.map(new UserMap()).print();env.execute();}public static class UserMap implements MapFunctionWaterSensor, String {Overridepublic String map(WaterSensor e) throws Exception {return e.id;}} } 面代码中MapFunction实现类的泛型类型与输入数据类型和输出数据的类型有关。在实现MapFunction接口的时候需要指定两个泛型分别是输入事件和输出事件的类型还需要重写一个map()方法定义从一个输入事件转换为另一个输出事件的具体逻辑。 Filter filter转换操作顾名思义是对数据流执行一个过滤通过一个布尔条件表达式设置过滤条件对于每一个流内元素进行判断若为true则元素正常输出若为false则元素被过滤掉。 进行filter转换之后的新数据流的数据类型与原数据流是相同的。filter转换需要传入的参数需要实现FilterFunction接口而FilterFunction内要实现filter()方法就相当于一个返回布尔类型的条件表达式。 public class TransFilter {public static void main(String[] args) throws Exception {StreamExecutionEnvironment env StreamExecutionEnvironment.getExecutionEnvironment();DataStreamSourceWaterSensor stream env.fromElements(new WaterSensor(sensor_1, 1, 1), new WaterSensor(sensor_1, 2, 2), new WaterSensor(sensor_2, 2, 2), new WaterSensor(sensor_3, 3, 3));// 方式一传入匿名类实现FilterFunctionstream.filter(new FilterFunctionWaterSensor() {Overridepublic boolean filter(WaterSensor e) throws Exception {return e.id.equals(sensor_1);}}).print();// 方式二传入FilterFunction实现类// stream.filter(new UserFilter()).print();env.execute();}public static class UserFilter implements FilterFunctionWaterSensor {Overridepublic boolean filter(WaterSensor e) throws Exception {return e.id.equals(sensor_1);}} } FlatMap flatMap操作又称为扁平映射主要是将数据流中的整体一般是集合类型拆分成一个一个的个体使用。消费一个元素可以产生0到多个元素。flatMap可以认为是“扁平化”flatten和“映射”map两步操作的结合也就是先按照某种规则对数据进行打散拆分同map一样flatMap也可以使用Lambda表达式或者FlatMapFunction接口实现类的方式来进行传参返回值类型取决于所传参数的具体逻辑可以与原数据流相同也可以不同。 案例需求如果输入的数据是sensor_1只打印vc如果输入的数据是sensor_2既打印ts又打印vc。 public class TransFlatmap {public static void main(String[] args) throws Exception {StreamExecutionEnvironment env StreamExecutionEnvironment.getExecutionEnvironment();DataStreamSourceWaterSensor stream env.fromElements(new WaterSensor(sensor_1, 1, 1), new WaterSensor(sensor_1, 2, 2), new WaterSensor(sensor_2, 2, 2), new WaterSensor(sensor_3, 3, 3));stream.flatMap(new MyFlatMap()).print();env.execute();}/*** TODO flatmap 一进多出包含0出* 对于s1的数据一进一出* 对于s2的数据一进2出* 对于s3的数据一进0出类似于过滤的效果** map怎么控制一进一出* 》 使用 return** flatmap怎么控制的一进多出* 》 通过 Collector来输出 调用几次就输出几条***/public static class MyFlatMap implements FlatMapFunctionWaterSensor, String {Overridepublic void flatMap(WaterSensor value, CollectorString out) throws Exception {if (value.id.equals(sensor_1)) {out.collect(String.valueOf(value.vc));} else if (value.id.equals(sensor_2)) {out.collect(String.valueOf(value.ts));out.collect(String.valueOf(value.vc));}
http://www.huolong8.cn/news/389950/

相关文章:

  • 建设部网人事考试网站网站开发毕设开题报告
  • 毕设 网站开发的必要性福州产品网页制作的公司
  • 会昌网站百度推广客户端app下载
  • 企业商城建站上海政务网站建设
  • 建设银行招生网站定制小程序制作平台
  • 定州哪里可以做网站如何开电商平台
  • 合肥做网站cnfgwordpress 速度慢
  • asp网站后台验证码错误建设公司网站模板下载
  • 网站备案的流程做网站哪个平台
  • 网站设计动画杭州企业自助建站
  • 刷赞网站推广空间免费残疾人网站服务平台
  • 貴阳建设银行网站带m开头的网站怎么做
  • 医药公司网站建设备案安全的网站建设
  • 在哪个网站找婚照公司网站服务器和网站
  • 没有备案的网站百度能收录吗c2c网站建设策划书
  • 网站制作月薪多少wordpress term_group
  • 手机金融界网站做网站买空间用共享ip
  • 网站禁用右键无法解析服务器域名
  • 南皮做网站的全国十大物联网平台公司
  • 青海省住房和城乡建设厅 网站首页网站导航栏种类
  • 我的电脑做网站服务器百度关键词优化和百度推广
  • 深圳网站制作的公司深圳app开发技术培训机构排名前十
  • 百度网站结构企业策划案怎么写
  • 专业建设网站哪家好温州seo顾问
  • 在线制作flash的网站建立网站的连接结构有哪几种形式
  • 安装wordpress注意什么seo索引擎优化
  • 长沙网站外包wordpress快速注册
  • 河南艾特网站建设公司淘宝运营公司
  • 黄石建设信息网站福步外贸论坛怎样注册
  • 手机app下载网站wordpress 3.9.1下载