Bagaimana untuk Melaksanakan Operasi Nested GroupBy dalam Java 8 untuk Pengagregatan Data Kompleks?

Bersarang (Berbilang Tahap) GroupBy dalam Java 8

Penghimpunan berbilang peringkat dalam Java 8 membenarkan pengagregatan kompleks objek data berdasarkan pelbagai bidang. Dalam kes anda, anda mempunyai satu set kelas Pojo, Item dan SubItem dan anda mahu mengumpulkan item berdasarkan key1 dan kemudian subitem dalam kumpulan itu dengan key2.

Untuk mencapai ini, kita tidak boleh begitu sahaja gunakan panggilan Collectors.groupingBy bersarang, kerana ini tidak membenarkan pengumpulan dengan berbilang kunci daripada objek berbeza. Sebaliknya, kami menggunakan gabungan flatMap dan pengumpul kumpulan:

<code class="java">Map<T, Map<V, List<SubItem>>> result = pojo.getItems().stream()
    .flatMap(item -> item.getSubItems().stream()
        .map(sub -> new AbstractMap.SimpleImmutableEntry<>(item.getKey1(), sub)))
    .collect(Collectors.groupingBy(AbstractMap.SimpleImmutableEntry::getKey,
                Collectors.groupingBy(Map.Entry::getValue, Collectors.toList())));</code>

Dalam pendekatan ini, kami mula-mula menggunakan flatMap untuk mencipta aliran pasangan yang mengandungi kunci1 daripada setiap Item dan SubItem yang sepadan. Kemudian, kami menggunakan Collectors.groupingBy dua kali: sekali untuk mengumpulkan pasangan mengikut kekunci1 dan sekali lagi untuk mengumpulkan SubItem mengikut kekunci2.

Penyelesaian alternatif ialah mentakrifkan pengumpul tersuai yang menyediakan operasi Pemetaan rata yang serupa dengan Java 9 Collectors.flatMapping:

<code class="java">static <T,U,A,R> Collector<T,?,R> flatMapping(
    Function<? super T,? extends Stream<? extends U>> mapper,
    Collector<? super U,A,R> downstream) {

    BiConsumer<A, ? super U> acc = downstream.accumulator();
    return Collector.of(downstream.supplier(),
        (a, t) -> { try(Stream<? extends U> s=mapper.apply(t)) {
            if(s!=null) s.forEachOrdered(u -> acc.accept(a, u));
        }},
        downstream.combiner(), downstream.finisher(),
        downstream.characteristics().toArray(new Collector.Characteristics[0]));
}</code>

Dengan pengumpul tersuai ini, operasi pengumpulan boleh dipermudahkan:

<code class="java">Map<T, Map<V, List<SubItem>>> result = pojo.getItems().stream()
    .collect(Collectors.groupingBy(Item::getKey1,
                Collectors.flatMapping(item -> item.getSubItems().stream(),
                    Collectors.groupingBy(SubItem::getKey2))));</code>

Atas ialah kandungan terperinci Bagaimana untuk Melaksanakan Operasi Nested GroupBy dalam Java 8 untuk Pengagregatan Data Kompleks?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!