Spark programming

 

 

 

Spark :

 

map(func)

 

Returns a new distributed dataset, formed by passing each element of the source through a function func.

 

 

filter(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.

Existing Users Log In
 Remember Me