score:37

Accepted answer

you should import the implicit conversions from sparkcontext:

import org.apache.spark.sparkcontext._

they use the 'pimp up my library' pattern to add methods to rdd's of specific types. if curious, see sparkcontext:1296

score:0

if you use maven on scalaide i just solved the problem by updating the dependency from spark-streaming version 1.2 to version 1.3.

score:0

actually, you can find it in pairrddfunctions class. pairrddfunctions is a class contains extra functions available on rdds of (key, value) pairs through an implicit conversion.

https://spark.apache.org/docs/2.1.0/api/scala/index.html#org.apache.spark.rdd.pairrddfunctions


Related Query

More Query from same tag