Функция mapValues ​​в классе DStream не найдена

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

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

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

Источник

1 ответ

import org.apache.spark.streaming.StreamingContext.toPairDStreamFunctions

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

Источник
Другие вопросы по тегам