我对 Java Stream.flatMap 的理解正确吗？答案

【问题标题】：Is my understanding of Java Stream.flatMap correct?我对 Java Stream.flatMap 的理解正确吗？
【发布时间】：2020-03-05 06:37:53
【问题描述】：

我试图回答这个question，但我没有回答，因为我不太了解 Streams。请告诉我我的解释是否正确。

我的回答：

import java.util.Arrays;
import java.util.stream.Stream;

public class Temp {
    public static void main(String [] args){
        String [] input = {"1,2", "3,4", "5"};
        String [] expected = {"1", "2", "3", "4", "5"};

        String [] actual = Stream.of(input)
                .flatMap(s -> Arrays.stream(s.split(",")))
                .toArray(String [] :: new);

        //Testing - Runs only when assertions are enabled for your JVM. Set VM args = -ea for your IDE.
        assert Arrays.equals(actual, expected) : "Actual array does not match expected array!";
    }
}

我的解释：

1 - 获取一个元素流（本例中为字符串）并一次将一个元素传递给flatMap。

问题 - 这实际上是一次一个元素吗？

2 - flatMap 采用 Function 将元素转换为 Stream。在示例中，该函数接受一个字符串（“1,2”）并将其转换为多个字符串（“1”、“2”）的流。多个字符串的流由 Arrays.stream(an array) 生成，我们知道它接受一个数组并将其转换为流。该数组由s.split(",") 生成。所有其他元素都被处理并放入这个流中。

问题 - flatMap 是为输入数组中的所有元素返回一个流，还是为输入数组的每个元素返回一个流？

3 - toArray 从flatMap 获取的单个流中获取元素并将它们放入一个数组中。

【问题讨论】：

(1) 是的。 (2) Function 为原始流中的每个元素返回一个流，允许flatMap 返回一个包含所有“扁平化”元素的流。 (3) 太宽泛的问题；要真正了解流的工作原理，我建议查看源代码。
试试这个 - String[] actual = Stream.of(input) .flatMap(s -> Arrays.stream(s.split(","))) .peek(System.out::println) .toArray(String[]::new); 然后与 String[] actual = Stream.of(input) .peek(System.out::println) .flatMap(s -> Arrays.stream(s.split(","))) .peek(System.out::println) .toArray(String[]::new); 比较。它会帮助您自行确认。
模糊的标题。重写以总结您的具体技术问题。
@Slaw - 我通过删除最后一个问题将问题更新为更具体。
虽然流“一次处理一个元素”是正确的，但您无需担心。您已经为每个元素定义了一个操作，处理顺序无关紧要。

标签： java lambda java-stream

【解决方案1】：

平面地图的预定义语法是

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

where, R is the element type of the new stream.
Stream is an interface and T is the type 
of stream elements. mapper is a stateless function 
which is applied to each element and the function
returns the new stream.

那么 flatMap 在内部是如何工作的呢？

它首先将返回另一个 Optional 的函数应用于内部对象（如果存在），然后在返回之前将结果展平，因此您不必自己做。

在内部它定义了这样的东西

public static <T> Optional<T> flatten(Optional<Optional<T>> optional) {
    return optional.orElse(Optional.empty());
}

所以你的情况

String [] actual = Stream.of(input)
            .flatMap(s -> Arrays.stream(s.split(",")))
            .toArray(String [] :: new);

StreamofInput(input)  - taking input as collection
flatMap: adding map function
s-> Arrays.stream(s.split(","))- taking argument from your arrays individually which is represent by "s" , then converting your array which is splitted by "," and converting into stream.
toArray : converting you result into flat single array because its stateless so it will give you new collection.

更多信息您可以访问here

【讨论】：