第 11 章 流
您可能需要处理一个子集或缓存中的所有数据来生成结果。这可能会造成 Map Reduce 的想法。Data Grid 允许用户执行类似内容,但利用标准的 JRE API 来执行此操作。Java 8 引入了一个流( Stream )的概念,它允许对集合进行功能风格的操作,而不是自行迭代数据。流操作可以以类似 MapReduce 的方式实施。流,就像 MapReduce 一样,您可以对整个缓存执行处理,这可能是一个非常大的数据集,但采用效率。
注意
在处理缓存中存在的数据时,流是首选的方法,因为流会自动调整集群拓扑更改。
另外,由于我们可以控制条目在我们如何迭代,因此如果您希望它同时在集群中执行所有操作,则可以更有效地在缓存中执行操作。
通过调用 stream 或 parallelStream 方法,从 entrySet、keySet 或 values 集合 从缓存 返回的流检索。
11.1. 常见流操作
本节重点介绍了您正在使用的底层缓存类型的各种选项。