42 - Spark RDD Transformations - flatMap() - Code Demo 2 смотреть онлайн

@backstreetbrogrammer

--------------------------------------------------------------------------------
Chapter 07 - Spark RDD Transformations - flatMap() - Code Demo 2
--------------------------------------------------------------------------------
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/backstreetbrogrammer/11_JavaSpark

- Apache Spark for Java Developers Playlist: https://youtube.com/playlist?list=PLQDzPczdXrTgqEc0uomGYDS0SFu7qY3g3
- Top Java Coding Interview Problems Playlist: https://www.youtube.com/playlist?list=PLQDzPczdXrTiEt7nlXb66dgiAjXhhUAUU
- Java Serialization Playlist: https://youtube.com/playlist?list=PLQDzPczdXrTjGLkI8kd2d0bfNHx0v7dTy
- Dynamic Programming Playlist: https://youtube.com/playlist?list=PLQDzPczdXrTilRgmNUQ632OrD-wfRLUR_

#java #javadevelopers #javaprogramming #apachespark #spark