容器Stream

Posted 2023-02-22

参考技术A

Map：处理数据

Reduce：分析数据

处理数据需要用到Stream数据流。

在Collection接口中除抽象方法还定义有一些default方法可以直接拿来用的：

范例：

相对来说还是用Iterator好用一点。

Stream类中含有filter方法： Stream<T> filter(Predicate<? super T> predicate)

filter 接收一个断言型函数式接口参数。

可以直接向方法中写lambda，编译器会帮我们识别是Predicate接口类型的然后将lambda的内容写到接口的test方法中，返回布尔值。filter方法中会调用predicate.test()。

Stream实现数据过滤：

当我们需要具体的数据时就需要用到Stream的collect方法了

Stream有两个重要的方法：

MapReduce是整个Stream操作的核心所在。主要由两个阶段组成：

范例：