java - 从一个长流创建流

Question

我想分单Stream进入Stream的 Streams基于Streams的内容.结果 Stream应包含部分原始流数据。

我的实际应用程序更复杂(它将时间间隔列表内的日志行分组)，但我的问题是如何处理流，所以这里我问一个简化的例子。

示例问题

我希望能够拆分 Stream<Integer>进入 Stream<Stream<Integer>>基于重复相同的数字，只留下奇数的流。

例如以下流包含:

{1,1,1,2,2,2,3,6,7,7,1,1}

需要产生包含以下内容的流:

{{1,1,1},{3},{7,7},{1,1}}

我可以通过使用过滤器开始(或结束)来排除偶数:

Stream<Integer> input = ...;
Straem<Stream<Integer>> output = input.filter(this::isOdd).someOtherOperation();

这是不受欢迎的，因为这意味着对每个输入值进行两次评估，这是可以接受的，但我宁愿避免这种情况。

解决方案的想法

我当前的解决方案是迭代流的内容并创建一个 List<List<Integer>>并将其转换为 Stream<Stream<Integer>> .然而，这意味着完整的结果保存在内存中(这对我的应用程序来说是不希望的)。

我也认为我可以通过编写自己的 Iterator 来解决这个问题从流中读取，但我不确定这将如何工作。

问题

如何转换 Stream进入Stream的 Streams基于原文内容Stream ，而不将完整结果存储为 List的 Lists第一的。

Answer 1

您可能想要实现自己的 aggregating spliterator去做这个。 proton-pack 中已有类似内容库(第一个链接重定向到质子包中实现的那个)。

请注意，您得到一个 Stream<List<Integer>> (您可以尝试修改实现以直接拥有一个 Stream<Stream<Integer>>，但您总是需要缓冲少量元素；取决于窗口的大小；以测试您是否应该创建一个新窗口)。例如:

StreamUtils.aggregate(Stream.of(1, 1, 1, 2, 2, 2, 3, 6, 7, 7, 1, 1), 
                      Objects::equals)
           .forEach(System.out::println);

输出:

[1, 1, 1]
[2, 2, 2]
[3]
[6]
[7, 7]
[1, 1]