Java 8 Lambda 同时分组 X 和 Y

标签 java lambda java-8

我正在寻找一个 lambda 来优化已经检索到的数据。我有一个原始结果集,如果用户不更改我想使用 java 的 lambda 按结果分组的日期。我是 lambda 的新手。

我正在寻找的 lambda 与此查询的工作方式类似。

select z, w, min(x), max(x), avg(x), min(y), max(y), avg(y) from table group by x, w;

最佳答案

所以我假设您有一个对象列表,并且您想要创建一个具有给定分组的 map 。我对你的 x、y、w、z 有点困惑,所以我将使用我自己的字段。但我会这样做:

interface Entry {
    String getGroup1();
    String getGroup2();
    int getIntData();
    double getDoubleData();
}

List<Entry> dataList;
Map<String, Map<String, IntSummaryStatistics>> groupedStats = 
    dataList.stream()
        .collect(Collectors.groupingBy(Entry::getGroup1,
            Collectors.groupingBy(Entry::getGroup2,
                Collectors.summarizingInt(Entry::getIntData))));

然后如果你想得到,比方说,组 A,B 的项目的平均数据然后你使用:

groupedStats.get("A").get("B").getAverage();

如果您想同时汇总多个数据集,那么它会变得有点复杂。您需要编写自己的可以累积多个统计信息的包装类。这是一个在 Entry 中包含两个数据项的示例(我将它们设为 int 和 double 以使其更有趣)。

class CompoundStats {
    private final IntSummaryStatistics intDataStats = new IntSummaryStatistics();
    private final DoubleSummaryStatistics doubleDataStats = new DoubleSummaryStatistics();

    public void add(Entry entry) {
        intDataStats.accept(entry.getIntData());
        doubleDataStats.accept(entry.getDoubleData());
    }

    public CompoundStats combine(CompoundStats other) {
        intDataStats.combine(other.intDataStats);
        doubleDataStats.combine(other.doubleDataStats);
        return this;
    }
}

然后可以使用此类创建您自己的收集器:

Map<String, Map<String, CompoundStats>> groupedStats = 
    dataList.stream()
        .collect(Collectors.groupingBy(Entry::getGroup1,
            Collectors.groupingBy(Entry::getGroup2,
                Collector.of(CompoundStats::new, CompoundStats::add, CompoundStats::combine))));

现在您的 map 返回 CompoundStats 而不是 IntSummaryStatistics:

groupedStats.get("A").get("B").getDoubleStats().getAverage();

另请注意,如果您创建一个单独的类来保存您的分组而不是使用我上面建议的两步图,这会更整洁。如果需要,这也不是一个困难的修改。

希望这对您自己的情况有用。

关于Java 8 Lambda 同时分组 X 和 Y,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/28074841/

相关文章:

java - 如何使用java流创建一个固定长度和特定数字的int[]?

java - 通过反射获取HashMap

java - 查找RadioGroup时出现空指针异常

java - Gradle在编译时包含jar,但排除运行时

java - 如何根据两个自定义对象删除列表中的重复项

c++ - 捕获对象的内部范围以供在函数中使用

C# => 运算符?

maven - 在 App Engine Standard 上部署时无法生成 quickstart.xml

python - 高效计算字符串中的词频

java - ForkJoinPool、Phaser 和托管阻塞 : to what extent do they works against deadlocks?