43 - Spark RDD Transformations - filter() - Code Demo
@backstreetbrogrammer
--------------------------------------------------------------------------------
Chapter 07 - Spark RDD Transformations - filter() - Code Demo
--------------------------------------------------------------------------------
Transformation: filter(func)
Return a new dataset formed by selecting those elements of the source on which func returns true.
As RDDs are immutable, after applying the filter transformation, new RDD is created.
Example:
final var words = lines.flatMap(line -: List.of(line.split("\\s")).iterator());
final var filteredWords = words.filter(word -: ((word != null) && (word.trim().length() greater than 0)));
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