使用 Java 8 的复杂自定义收集器

我有一个对象流，我想通过以下方式收集它们。

假设我们正在处理论坛posts:

class Post {
    private Date time;
    private Data data
}

我想创建一个列表，其中包含哪些组posts通过一段时间。如果没有posts for X分钟，创建一个新组.

class PostsGroup{
    List<Post> posts = new ArrayList<> ();
}

我想得到一个List<PostGroups>含有posts按区间分组。

Example:的间隔10分钟。

Posts:

[{time:x, data:{}}, {time:x + 3, data:{}} , {time:x + 12, data:{}, {time:x + 45, data:{}}}]

我想要一份清单帖子组:

[
 {posts : [{time:x, data:{}}, {time:x + 3, data:{}}, {time:x + 12, data:{}]]},
{posts : [{time:x + 45, data:{}]}
]

• 请注意，第一个group一直持续到X + 22。然后一个new post收到于X + 45.

这可能吗？

这个问题可以很容易地解决，使用groupRuns http://amaembo.github.io/streamex/javadoc/one/util/streamex/StreamEx.html#groupRuns-java.util.function.BiPredicate-我的方法StreamEx https://github.com/amaembo/streamex图书馆：

long MAX_INTERVAL = TimeUnit.MINUTES.toMillis(10);
StreamEx.of(posts)
        .groupRuns((p1, p2) -> p2.time.getTime() - p1.time.getTime() <= MAX_INTERVAL)
        .map(PostsGroup::new)
        .toList();

我假设你有一个构造函数

class PostsGroup {
    private List<Post> posts;

    public PostsGroup(List<Post> posts) {
        this.posts = posts;
    }
}

The StreamEx.groupRuns方法需要一个BiPredicate它应用于两个相邻的输入元素，如果它们必须分组在一起，则返回 true。此方法创建列表流，其中每个列表代表一个组。此方法是惰性的，并且适用于并行流。