Strona główna / Streams / Collectors.flatMapping()
Streams Średniozaawansowany

Collectors.flatMapping()

Użyj flatMapping() do spłaszczania wewnątrz kolektora grupującego.

Porównanie kodu
✕ Java 8 
// Flatten within a grouping collector
// Required complex custom collector
Map<String, Set<String>> tagsByDept =
    // no clean way in Java 8
✓ Java 9+ 
var tagsByDept = employees.stream()
    .collect(groupingBy(
        Emp::dept,
        flatMapping(
            e -> e.tags().stream(),
            toSet()
        )
    ));
Widzisz problem z tym kodem? Daj nam znać.
Dlaczego nowoczesne podejście wygrywa
🧩

Kompozycyjność

Działa jako kolektor downstream wewnątrz groupingBy.

📐

Jeden przebieg

Spłaszczanie i grupowanie wykonujesz w jednym przejściu strumienia.

🔗

Zagnieżdżanie

Łatwo łączysz z innymi kolektorami downstream.

Stare podejście
Zagnieżdżone flatMap
Nowoczesne podejście
flatMapping()
Od JDK
9
Poziom trudności
Średniozaawansowany
Wsparcie JDK
Collectors.flatMapping()
Dostępne

Szeroko dostępne od JDK 9 (wrzesień 2017)

Jak to działa

Collectors.flatMapping() stosuje mapowanie one-to-many jako kolektor downstream. To odpowiednik Stream.flatMap() po stronie kolektorów, przydatny np. wewnątrz groupingBy lub partitioningBy.

Powiązana dokumentacja
Collectors.flatMapping() ↗
Powiązane wzorce
Streams Początkujący

Optional.ifPresentOrElse()

Java 8
Optional<User> user = findUser(id);
if (user.isPresent()) {
    greet(user.get());
} else {
    handleMissing();
}
Java 9+
findUser(id).ifPresentOrElse(
    this::greet,
    this::handleMissing
);
Najedź, aby zobaczyć nową wersję ➜
JDK 9+ →
Streams Początkujący

Stream.ofNullable()

Java 8
Stream<String> s = val != null
    ? Stream.of(val)
    : Stream.empty();
Java 9+
Stream<String> s =
    Stream.ofNullable(val);
Najedź, aby zobaczyć nową wersję ➜
JDK 9+ →
Streams Średniozaawansowany

Stream.iterate() with predicate

Java 8
Stream.iterate(1, n -> n * 2)
    .limit(10)
    .forEach(System.out::println);
// can't stop at a condition
Java 9+
Stream.iterate(
    1,
    n -> n < 1000,
    n -> n * 2
).forEach(IO::println);
// stops when n >= 1000
Najedź, aby zobaczyć nową wersję ➜
JDK 9+ →
Udostępnij 𝕏 🦋 in ⬡