40 - Spark RDD Transformations - map() using reduce() - Code Demo 3

preview_player
Показать описание
@backstreetbrogrammer

--------------------------------------------------------------------------------
Chapter 07 - Spark RDD Transformations - map() using reduce() - Code Demo 3
--------------------------------------------------------------------------------
Transformation: map(func)
Return a new distributed dataset formed by passing each element of the source through a function func.

As RDDs are immutable, after applying the map transformation, new RDD is created.

The func is applied to each element, mapping it into a new element (the word mapping is used because it has a meaning similar to transforming but with the nuance of “creating a new version of” rather than “modifying”).

Example:

#java #javadevelopers #javaprogramming #apachespark #spark
Рекомендации по теме
Комментарии
Автор

Hi Rishi, Can you please elaborate.. why you are iterating your code 10 or n times in every example. What purpose or functionality this is demonstrating.

amarjeetmalik