如何使用Java8lambda从stream中获取一系列项目？

Question

在前面的一个问题[How to dynamic do filtering In Java8？]中，Stuart Marks给出了一个很好的答案，并提供了几个有用的实用程序来处理从Stream中选择topN和topperty。

我将把他最初的回答包括在这里：

@FunctionalInterface
public interface Criterion {
    Stream<Widget> apply(Stream<Widget> s);
}

Criterion topN(Comparator<Widget> cmp, long n) {
    return stream -> stream.sorted(cmp).limit(n);
}

Criterion topPercent(Comparator<Widget> cmp, double pct) {
    return stream -> {
        List<Widget> temp =
            stream.sorted(cmp).collect(toList());
        return temp.stream()
                   .limit((long)(temp.size() * pct));
    };
}

我的问题是：

[1]如何从具有一定数量项目的流中获得从3到7的顶级项目，所以如果流中有来自A1、A2的项目..A10，呼叫

topNFromRange(Comparator<Widget> cmp, long from, long to) = topNFromRange(comparing(Widget::length), 3L, 7L)

将返回{A3,A4,A5,A6,A7}

我能想到的最简单的方法是从原版中得到前7[T7]，从原版中得到前3[T3]，然后得到T7-T3。

[2]如何从一个有一定数量项目的流中从前10%到前30%获得顶级项目，所以如果流中有来自X1的项目，X2.X100，调用

topPercentFromRange(Comparator<Widget> cmp, double from, double to) = topNFromRange(comparing(Widget::length), 0.10, 0.30)

将返回{X10,X11,X12,...,X29,X30}

Answer 1

用户skiwi已经回答了问题的第一部分。第二部分是：

（2）如何从一个有一定数量物品的流中获得前10%到前30%的顶级物品....

要做到这一点，您必须使用与我在回答另一个问题时使用的toppercent类似的技术。也就是说，您必须将元素收集到一个列表中，以便能够获得元素的计数，可能是在完成了一些上游过滤之后。

获得计数后，根据计数和所需百分比计算skip和limit的正确值。类似这样的方法可能会奏效：

Criterion topPercentFromRange(Comparator<Widget> cmp, double from, double to) {
    return stream -> {
        List<Widget> temp =
            stream.sorted(cmp).collect(toList());
        return temp.stream()
                   .skip((long)(temp.size() * from))
                   .limit((long)(temp.size() * (to - from)));
    };
}

当然，您必须对从和到进行错误检查。一个更微妙的问题是确定发射多少元素。例如，如果您有十个元素，它们位于索引[0..9]，对应于0%、10%、20%、...、90%。但是如果您要求的范围是9%到11%，上面的代码将不会发出任何元素，而不是像您所期望的那样10%的元素。因此，可能有必要对百分比计算进行一些修修补补，以适应您所要做的事情的语义。