第 10 章 流
您可能希望处理缓存中的子集或所有数据来生成结果。这可能会对映射带来影响。Data Grid 允许用户执行非常相似,但使用标准的 JRE API 这样做。Java 8 引入了一个 流 的概念,允许对集合进行功能风格的操作,而不必自行迭代数据。流操作可以通过与 MapReduce 非常相似来实现。与 MapReduce 一样,流允许您对整个缓存执行处理,可能是一个非常大的数据集,但效率更高。
注意
在处理缓存中存在的数据时,流是首选的方法,因为流会自动调整集群拓扑更改。
此外,我们还可以控制如何在什么情况下迭代条目,如果您希望同时对集群执行所有操作,则该缓存中可以更有效地执行操作。
通过调用 stream 或 parallelStream 方法,从 entrySet、keySet 或 value 集合检索流。https://access.redhat.com/webassets/avalon/d/red-hat-data-grid/8.3/api/org/infinispan/Cache.html#values--
10.1. 常见流操作
本节重点介绍了各种选项,无论您使用的底层缓存类型是什么。