sample is not a member of org.apache.spark.streaming.dstream.DStream

[Josh J]

Hi,

I'm trying to using sampling with Spark Streaming. I imported the following

import org.apache.spark.{SparkConf, SparkContext}
import org.apache.spark.SparkContext._


I then call sample


val streamtoread = KafkaUtils.createStream(ssc, zkQuorum, group,
topicMap,StorageLevel.MEMORY_AND_DISK).map(_._2)

streamtoread.sample(withReplacement = true, fraction = fraction)


How do I use the sample
<http://spark.apache.org/docs/latest/programming-guide.html#transformations>()
method with Spark Streaming?


Thanks,

Josh