Returns a new distributed dataset, formed by passing each element of the source through a function func.
val filterWord= sparkIn.filter( line.contains(“what”))
Returns a new dataset formed (more…)
This content is restricted to site members. If you are an existing user, please log in. New users may register below.