mapValues ​​в классе DStream Не найдено

Question

Я хочу внести некоторые изменения в алгоритм StreamingKMeans, предоставленный в Spark Streaming, поэтому я создал проект, содержащий необходимые файлы, но, к сожалению, я не могу найти функцию mapValues ​​в классе DStream!

def predictOnValues[K: ClassTag](data: DStream[(K, Vector)]): DStream[(K, Int)] = { 
    assertInitialized() 
    data.mapValues(model.predict) //ERROR here !!! 
} 

Может ли кто-нибудь сказать мне, где я могу найти функцию mapValues?! Благодарю.

Answer 1

импорт org.apache.spark.streaming.StreamingContext.toPairDStreamFunctions

должен это исправить.