我在下面的代码中遇到了问题:
class Review(label: Double, features:org.apache.spark.ml.linalg.Vector)
def transformDataTFIDF(plainText: RDD[String],reviewClass:String,label:Int,numTerms:Int): org.apache.spark.sql.Dataset[Review] = {
val lemmatized = plainText.zipWithIndex.map(_.swap).mapPartitions(iter => {
val pipeline = createNLPPipeline();
iter.map{ case(id, contents) => (id.toString(),
plainTextToLemmas(contents, stopWords, pipeline))
};
}).cache()
val (termDocMatrix, termIds, docIds, idfs) = termDocumentMatrix(lemmatized, stopWords, numTerms, sc)
val vectorizedReviewsMap = Map( reviewClass -> termDocMatrix)
val ReviewsList = MutableList[Review]()
val ReviewsVecRDD = vectorizedReviewsMap(reviewClass).collect().foreach(v => ReviewsList += Review(label,v.asML))
ReviewsList.toDS()
}我得到了这个错误:
<console>:73: error: not found: value MutableList
val ReviewsList = MutableList [Review]()你能告诉我应该做些什么来纠正它吗?
发布于 2021-02-09 01:23:58
MutableList一直存在到Scala2.12。它在Scala 2.13中被删除了,你可能没有导入它。尝试:
import scala.collection.mutable
val ReviewsList = mutable.MutableList[Review]()或者:
val ReviewsList = scala.collection.mutable.MutableList[Review]()Scala 2.12中的工作代码片段和Scala 2.13中相同的非工作示例。
https://stackoverflow.com/questions/66106241
复制相似问题