0

我想对 Spark Streaming 中提供的 StreamingKMeans 算法做一些修改，所以我创建了一个包含必要文件的项目，但不幸的是我在 DStream 类中找不到 mapValues 函数！

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

有人能告诉我在哪里可以找到 mapValues 函数吗？！谢谢。

4

1 回答 1

0

导入 org.apache.spark.streaming.StreamingContext.toPairDStreamFunctions

应该修复它。

于 2015-04-10T16:35:32.883 回答