41 - Spark RDD Transformations - flatMap() - Code Demo 1
@backstreetbrogrammer
--------------------------------------------------------------------------------
Chapter 07 - Spark RDD Transformations - flatMap() - Code Demo 1
--------------------------------------------------------------------------------
Transformation: flatMap(func)
Similar to map, but each input item can be mapped to 0 or more output items (so func should return a Seq or Iterable rather than a single item).
As RDDs are immutable, after applying the flatMap transformation, new RDD is created.
However, in functional programming-language jargon, the flatMap method lets us replace each value of a stream with another stream and then concatenates all the generated streams into a single stream.
Example:
final var words = lines.flatMap(line -: List.of(line.split("\\s")).iterator());
Github: https://github.com/backstreetbrogramm...
Apache Spark for Java Developers Playlist: • Apache Spark for Java Developers
Top Java Coding Interview Problems Playlist: • Top Java Coding Interview Problems
Java Serialization Playlist: • Java Serialization
Dynamic Programming Playlist: • Dynamic Programming
#java #javadevelopers #javaprogramming #apachespark #spark