转载

Java8 Stream flatmap中间操作用法解析

stream中的flatmap是stream的一种中间操作，它和stream的map一样，是一种收集类型的stream中间操作，但是与map不同的是，它可以对stream流中单个元素再进行拆分（切片），从另一种角度上说，使用了它，就是使用了双重for循环。

查看Stream源码中flatmap的方法定义：

<R> Stream<R> flatMap(Function<? super T, ? extends Stream<? extends R>> mapper)

从方法的定义可以看出，其入参是一个函数式接口，该接口的返回类型应该是Stream< ? extends R > 类型的。

从实际需求中查看如何使用flatmap：

需求：有一个补习学校，其中有若干老师教学若干门课程，现在学校有关于数学教学的通知要传达给所有学数学的学生家长，将电子邮件发送到他们的邮箱中。

注意：一个老师可以教学多个科目，一个老师可以教学多个学生，一个学生可以报名多个科目，一个学生可以有多个家长。

数据结构(均省略get/set, toString ,构造器)：

// 老师
public class Teacher {
  private String id;
  private String name;
  private String subject;
}
// 学生
public class Student {
  private String id;
  private String name;
  private String techId;
  // 重写hashCode及equals方法(id及name相同就为同一个学生)
}
// 家长
public class Parents {
  private String id;
  private String name;
  private String chirldId;
  private String email;
}
// 课程
public enum Subject {
  private String value;
  private String desc;
  Subject(String value, String desc) {
    this.value = value;
    this.desc = desc;
  }
  Math("1", "数学"),
  Chinese("2", "汉语"),
  Music("3", "音乐"),
  English("4", "英语");
}

实际上的处理也比较简单:

1、找出教学科目为“数学”的老师；

2、找到这些老师对应的学生；

3、根据学生找到对应的家长。

直接贴代码：

public class Test {
  // 模拟数据
  public static Student s1 = new Student("1", "zhangsan", "001");
  public static Student s2 = new Student("2", "lisi", "001");
  public static Student s3 = new Student("3", "wangwu", "001");
  public static Student s4 = new Student("4", "zhaoliu", "001");
  public static Student s5 = new Student("6", "tianqi", "001");
  public static Student s6 = new Student("6", "tianqi", "002");
  public static Student s7 = new Student("6", "tianqi", "003");
  public static Teacher t1 = new Teacher("001", "xiaoming", Subject.Math.getValue());
  public static Teacher t2 = new Teacher("002", "lihua", Subject.Music.getValue());
  public static Teacher t3 = new Teacher("003", "hanmeimei", Subject.Math.getValue());
  public static Teacher t4 = new Teacher("004", "lihua", Subject.English.getValue());
  public static List<Student> stus = new ArrayList<>();
  public static List<Teacher> teacs = new ArrayList<>();
  static {
    stus.add(s1);
    stus.add(s2);
    stus.add(s3);
    stus.add(s4);
    stus.add(s5);
    stus.add(s6);
    stus.add(s7);
    teacs.add(t1);
    teacs.add(t2);
    teacs.add(t3);
    teacs.add(t4);
  }

  public static void main(String[] args) {
    // 找到所有数学老师的学生的家长的电话,并找他们开家长会
    List<Parents> collect = teacs.stream()
        // 过滤数学老师
        .filter(t -> Subject.Math.getValue().equals(t.getSubject()))
        // 通过老师找学生
        .flatMap(t -> stus.stream().filter(s -> s.getTechId().equals(t.getId())))
        // 过滤重复的学生(使用student的equals和hashCode方法)
        .distinct()
        // 通过学生找家长(这里就简化为创建家长对象)
        .map(s -> {
          Parents p = new Parents();
          p.setId(UUID.randomUUID().toString());
          p.setChirldId(s.getId());
          p.setName(s.getName().toUpperCase() + "'s Parent");
          p.setEmail((int) (Math.random() * 1000000) + "@qq.com");
          return p;
        })
        .collect(Collectors.toList());
    // 打印到控制台看看
    collect.stream()
        .forEach(System.out::println);
  }
}

运行结果:

Parents{id='3d9312eb-0df5-4ec6-998f-94a32c2253b4', name='LISI's Parent', chirldId='2', telNo='844668@qq.com'}  Parents{id='7f0b92f5-872d-4671-982d-ef1b48840ce3', name='WANGWU's Parent', chirldId='3', telNo='563932@qq.com'}  Parents{id='c318bffd-8c6d-4849-8109-9c686c97fb77', name='ZHAOLIU's Parent', chirldId='4', telNo='108022@qq.com'}  Parents{id='a4ff1bbc-c9b6-4ad2-872c-f4df670c7bb6', name='TIANQI's Parent', chirldId='6', telNo='658956@qq.com'}

如果不使用stream，写该部分代码的效果，可能还有优化的空间，但是不够使用stream处理方式更为简洁，方便：

public class Test {
  public static void main(String[] args) {
    List<Parents> pars = new ArrayList<>();
    Set<Student> targetStudents = new HashSet<>();
    for (Teacher t : teacs) {
      if (t.getSubject().equals(Subject.Math.getValue())) {
        for (Student s : stus) {
          if (s.getTechId().equals(t.getId())) {
            targetStudents.add(s);
          }
        }
      }
    }
    for (Student s : targetStudents) {
      Parents p = new Parents();
      p.setId(UUID.randomUUID().toString());
      p.setChirldId(s.getId());
      p.setName(s.getName().toUpperCase() + "'s Parent");
      p.setEmail((int) (Math.random() * 1000000) + "@qq.com");
      pars.add(p);
    }
    for (Parents p : pars) {
      System.out.println(p);
    }
  }
}

再去看stream中的flatmap方法，它的作用就和他的名字flat一样，对于调用flatmap的流的每一个元素，执行flatmap入参中的函数式方法，由于该函数式方法必须返回一个stream<T>类型的流，这样对于调用flatmap的操作来说，就收集了另一种类型(<T>)的流，并在后续的操作中将<T>类型进行合并，最终产生一个stream<T>的流，而不是一个stream<stream<T>>类型的流。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持我们。

时间：2020-07-15

java8 stream自定义分组求和并排序的实现

本文主要介绍了java8 stream自定义分组求和并排序的实现,分享给大家,具体如下: public static void main(String[] args) { List<GroupDetailDTO> list = new ArrayList<>(); GroupDetailDTO dto1 = new GroupDetailDTO(); dto1.setHeadsetId(1); dto1.setTime("2020-01-03"); dto1.s

Java 8 Stream 的终极技巧——Collectors 功能与操作方法详解

本文实例讲述了Java 8 Stream 的终极技巧--Collectors 功能与操作方法.分享给大家供大家参考,具体如下: 1. 前言昨天在 Collection移除元素操作相关的文章中提到了 Collectors .相信很多同学对这个比较感兴趣,那我们今天就来研究一下 Collectors . 2. Collectors 的作用 Collectors 是 Java 8 加入的操作类,位于 java.util.stream 包下.它会根据不同的策略将元素收集归纳起来,比如最简单常用的是将

详解Java8新特性Stream之list转map及问题解决

List集合转Map,用到的是Stream中Collectors的toMap方法:Collectors.toMap 具体用法实例如下: //声明一个List集合 List<Person> list = new ArrayList(); list.add(new Person("1001", "小A")); list.add(new Person("1002", "小B")); list.add(new Person

Java InputStream的多种使用详解

以前写东西,尤其是网络传输方面总会碰到将某种格式的文本或者图片等转幻成数据流的方式来传输,那时候用的就直接网上找点就粘贴,也没什么搞懂到底是怎么个机理.后来抽点空就死啃了点这方面的文章,稍微懂了点,特意分享一下. InputStream FileInputStream BufferInputStream InputStreamreader ByteArrayInputStream这些东西到底什么关系呢? 一.首先我先理解InputStream是老大,剩下的这些都是为其服务的,先建立一个标准,

JAVA8 STREAM COLLECT GROUPBY分组实例解析

这篇文章主要介绍了JAVA8 STREAM COLLECT GROUPBY分组实例解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下实体类People,有个返回list的buildPeopleList方法,方便测试. import lombok.AllArgsConstructor; import lombok.Builder; import lombok.Data; import lombok.NoArgsConstructor; impo

es6数组的flat()，flatMap()函数用法实例分析

本文实例讲述了es6数组的flat(),flatMap()函数用法.分享给大家供大家参考,具体如下: 数组的成员有时还是数组,Array.prototype.flat()用于将嵌套的数组"拉平",变成一维数组.该方法返回一个新数组,对原数据没有影响. [1, 2, [3, 4]].flat() // [1, 2, 3, 4] 上面代码中,原数组的成员里面有一个数组,flat()方法将子数组的成员取出来,添加在原来的位置. flat()默认只会"拉平"一层,如果想要&

浅析scala中map与flatMap的区别

在函数式语言中,函数作为一等公民,可以在任何地方定义,在函数内或函数外,可以作为函数的参数和返回值,可以对函数进行组合.由于命令式编程语言也可以通过类似函数指针的方式来实现高阶函数,函数式的最主要的好处主要是不可变性带来的.没有可变的状态,函数就是引用透明(Referential transparency)的和没有副作用(No Side Effect). 任何一种函数式语言中,都有map函数与faltMap这两个函数,比如python虽然不是纯函数式语言,也有这两个函数.再比如在jdk1.8之后

Java 8 Stream Api 中的 map和 flatMap 操作方法

1.前言 Java 8提供了非常好用的 Stream API ,可以很方便的操作集合.今天我们来探讨两个 Stream中间操作 map(Function<? super T, ? extends R> mapper) 和 flatMap(Function<? super T, ? extends Stream<? extends R>> mapper) 2. map 操作 map 操作是将流中的元素进行再次加工形成一个新流.这在开发中很有用.比如我们有一个学生集合,我们

浅谈Spark RDD API中的Map和Reduce

RDD是什么? RDD是Spark中的抽象数据结构类型,任何数据在Spark中都被表示为RDD.从编程的角度来看,RDD可以简单看成是一个数组.和普通数组的区别是,RDD中的数据是分区存储的,这样不同分区的数据就可以分布在不同的机器上,同时可以被并行处理.因此,Spark应用程序所做的无非是把需要处理的数据转换为RDD,然后对RDD进行一系列的变换和操作从而得到结果.本文为第一部分,将介绍Spark RDD中与Map和Reduce相关的API中. 如何创建RDD? RDD可以从普通数组创建出来,

详解Java的Hibernat框架中的Map映射与SortedMap映射

Map映射 Map映射是一个java集合存储在键 - 值对的元素,并且不允许在列表中重复的元素. Map接口提供三种collection视图,允许Map内容看作是一组键-值集合,或者设置键 - 值映射关系. Map被映射到映射表中一个<map>元素和无序的地图可以在java.util.HashMap中被初始化. 定义RDBMS表: 考虑一个情况,我们需要员工记录存储在EMPLOYEE表,将有以下结构: create table EMPLOYEE ( id INT NOT NULL auto_i

详解Java的JDBC API中事务的提交和回滚

如果JDBC连接是在自动提交模式下,它在默认情况下,那么每个SQL语句都是在其完成时提交到数据库. 这可能是对简单的应用程序,但有三个原因,你可能想关闭自动提交和管理自己的事务: 为了提高性能为了保持业务流程的完整性使用分布式事务若要控制事务,以及何时更改应用到数据库.它把单个SQL语句或一组SQL语句作为一个逻辑单元,而且如果任何语句失败,整个事务失败. 若要启用,而不是JDBC驱动程序默认使用auto-commit模式手动事务支持,使用Connection对象的的setAutoComm

浅析Node.js 中 Stream API 的使用

本文由浅入深给大家介绍node.js stream api,具体详情请看下文吧. 基本介绍在 Node.js 中,读取文件的方式有两种,一种是用 fs.readFile ,另外一种是利用 fs.createReadStream 来读取. fs.readFile 对于每个 Node.js 使用者来说最熟悉不过了,简单易懂,很好上手.但它的缺点是会先将数据全部读入内存,一旦遇到大文件的时候,这种方式读取的效率就非常低下了. 而 fs.createReadStream 则是通过 Stream 来读取

Java 8中Stream API的这些奇技淫巧！你Get了吗？

上次老师跟大家分享了 cookie.session和token,今天给大家分享一下Java 8中的Stream API. Stream简介 1.Java 8引入了全新的Stream API.这里的Stream和I/O流不同,它更像具有Iterable的集合类,但行为和集合类又有所不同. 2.stream是对集合对象功能的增强,它专注于对集合对象进行各种非常便利.高效的聚合操作,或者大批量数据操作. 3.只要给出需要对其包含的元素执行什么操作,比如 "过滤掉长度大于 10 的字符串".&

Java中使用StackWalker和Stream API进行堆栈遍历

1.Java 9以前堆栈遍历到目前为止,官方解决方案是获取当前线程并调用其getStackTrace()方法: StackTraceElement[] stackTraceElements = Thread.currentThread().getStackTrace(); 另一个智能解决方案涉及.抛出异常并从中提取堆栈跟踪信息. 但是,无法操纵结果,它会立即打印出来: new Exception().printStackTrace(); 两种解决方案都存在同样的问题--它们都急切地捕获整个堆栈

Java8中Lambda表达式使用和Stream API详解

前言 Java8 的新特性:Lambda表达式.强大的 Stream API.全新时间日期 API.ConcurrentHashMap.MetaSpace.总得来说,Java8 的新特性使 Java 的运行速度更快.代码更少.便于并行.最大化减少空指针异常. 0x00. 前置数据 private List<People> peoples = null; @BeforeEach void before () { peoples = new ArrayList<>(); peoples

如何利用Java8 Stream API对Map按键或值排序

一.什么是Java 8 Stream 使用Java 8 Streams,我们可以按键和按值对映射进行排序.下面是它的工作原理: Java Stream函数式编程?用过都说好,案例图文详解送给你将Map或List等集合类对象转换为Stream对象使用Streams的sorted()方法对其进行排序最终将其返回为LinkedHashMap(可以保留排序顺序) sorted()方法以Comparator作为参数,从而可以按任何类型的值对Map进行排序.如果对Comparator不熟悉,可以看本号

javascript实现Java中的Map对象功能的实例详解

javascript 自定义对象实现Java中的Map对象功能 Java中有集合,Map等对象存储工具类,这些对象使用简易,但是在JavaScript中,你只能使用Array对象. 这里我创建一个自定义对象,这个对象内包含一个数组来存储数据,数据对象是一个Key,可以实际存储的内容! 这里Key,你要使用String类型,和Java一样,你可以进行一些增加,删除,修改,获得的操作. 使用很简单,我先把工具类给大家看下: /** * @version 1.0 * @author cuisuqia

原文 https://www.zhangshengrong.com/p/rG1V7GKVa3/

正文到此结束