gpt4 book ai didi

parallel-processing - 来自 JPA 存储库的 Java 8 流

转载 作者:行者123 更新时间:2023-12-05 01:02:44 24 4
gpt4 key购买 nike

我想从 JPA 存储库创建一个流。目标是将来自 Repo 的实体(可能超过一百万个)映射到其他实体,这些实体又将存储在另一个 Repo 中。

到目前为止,我构建了一个收集器,它将收集给定数量(例如 1000)个实体,然后将它们存储到目标 Repo 中。这将在并行流中工作。我现在需要的是一种从源 Repo 中获取实体并在需要时将它们提供给 Stream 的好方法。

迄今为止最有希望的是实现一个供应商( http://docs.oracle.com/javase/8/docs/api/java/util/function/Supplier.html )来通过 generate 构建流,但是当对源 Repo 的查询不提供另一个实体时,我没有找到终止该过程的方法。

任何指针?

最佳答案

我们最近在 Spring Data Fowler Release Train 的最新 RC1 版本中在 Spring Data JPA(和 MongoDB)中添加了对此的支持。

Example for Stream returned by a delegating default method
Example for "real streaming" Stream

关于parallel-processing - 来自 JPA 存储库的 Java 8 流,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/25896336/

24 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com