java中flatMap用法

java中map是把集合每个元素重新映射，元素个数不变，但是元素值发生了变化。而flatMap从字面上来说是压平这个映射，实际作用就是将每个元素进行一个一对多的拆分，细分成更小的单元，返回一个新的Stream流，新的流元素个数增加。

java官方给出的示例如下：

# 按行读取文件内容
Stream<String> lines = Files.lines(path);
# 将每一行文字按照空格拆分为单词
Stream<String> words = lines.flatMap(line -> Stream.of(line.split(" +")));

如下所示的文本：

hello world
this is a test txt
done

经过这个转换，得到的结果如下：

[hello, world, this, is, a, test, txt, done]

我们大概知道，flatMap压平的作用，就是把原来的三行字符串文字变为了一个流，流数组中每个元素是单词。

============

我们假设有这样的需求，有一个[[1,3],[2,4]]的二维数组，我们要得到一个一维数组[1,3,2,4]。那么这里的flatMap就正好排上用场，原来是二维的，现在压平为一维，正好分解了。

List<Integer> lista = new ArrayList<>();
lista.add(1);
lista.add(3);List<Integer> listb = new ArrayList<>();
listb.add(2);
listb.add(4);
List<List<Integer>> listc = new ArrayList<>();
listc.add(lista);
listc.add(listb);
System.out.println(listc);
List<Integer> listd = listc.stream().flatMap(ele -> ele.stream()).collect(Collectors.toList());
System.out.println(listd);

运行程序打印信息如下：

[[1, 3], [2, 4]]
[1, 3, 2, 4]

flatMap里面需要传入一个Function参数，这里根据需要将数组转为stream。其实可以直接传入一个函数名:Collection::stream，效果是一样的。

完整代码如下：

package org.example;import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;public class FlatMapExample {public static void main(String[] args) {List<Integer> lista = new ArrayList<>();lista.add(1);lista.add(3);List<Integer> listb = new ArrayList<>();listb.add(2);listb.add(4);List<List<Integer>> listc = new ArrayList<>();listc.add(lista);listc.add(listb);System.out.println(listc);List<Integer> listd = listc.stream().flatMap(Collection::stream).collect(Collectors.toList());System.out.println(listd);try {Stream<String> stream = Files.lines(Paths.get("test.txt"));// stream.forEach(System.out::println);List<String> words = stream.flatMap(line -> Stream.of(line.split(" +"))).collect(Collectors.toList());System.out.println(words);} catch (IOException e) {throw new RuntimeException(e);}}
}

运行截图：

Stream对象经过一次操作之后，内容就会被清除，同时流也被关闭。如果还进行第二次其他操作，那么就会报错：

stream has already been operated upon or closed

所以进行流操作，一般都是把所有的流程都以链式写法写在一起，最后得到结果。

java中flatMap用法相关推荐

java中import用法
java中import用法单类型导入(single-type-import),例如import java.io.File; 按需类型导入(type-import-on-demand),例如 impo ...
java中extends用法_JAVA的extends用法
理解继承是理解面向对象程序设计的关键.在Java中,通过关键字extends继承一个已有的类,被继承的类称为父类(超类,基类),新的类称为子类(派生类).在Java中不允许多继承. (1)继承 cla ...
java中continue用法
java中continue用法有时强迫一个循环提早反复是有用的,也就是,你可能想要继续运行循环,但是要忽略这次重复剩余的循环体的语句,所以 java提供了 continue 语句.continue ...
java中switch用法举例范围_Java中Switch用法代码示例
一.java当中的switch与C#相比有以下区别注:在java中switch后的表达式的类型只能为以下几种:byte.short.char.int(在Java1.6中是这样), 在java1.7后 ...
java中Iterator用法总结
Java中Iterator用法迭代器(Iterator) 迭代器是一种设计模式,它是一个对象,它可以遍历并选择序列中的对象,而开发人员不需要了解该序列的底层结构.迭代器通常被称为"轻量级& ...
java中nextInt()用法
java中nextInt用法功能函数实现三级目录功能给定一个参数n,nextInt(n)将返回一个大于等于0小于n的随机数,即:0 <= nextInt(n) < n. 函数实现 ...
cal java中的用法_Java中static用法
Java中static用法转自 http://blog.pfan.cn/sword2008/13772.html 一.static 请先看下面这段程序: public class Hello{ pu ...
JAVA中throw用法例子,Java Optional orElseThrow()用法及代码示例
Java中的java.util.Optional类的orElseThrow()方法用于获取此Optional实例(如果存在)的值.如果此Optional实例中不存在任何值,则此方法将引发从指定供应商生 ...
JAVA中this用法小结
我知道很多朋友都和我一样:在JAVA程序中似乎经常见到"this",自己也偶尔用到它,但是到底"this"该怎么用,却心中无数!很多人一提起它,就说" ...

java中flatMap用法

java中flatMap用法相关推荐

最新文章

热门文章