scala异常检测

zkure5ic  于 2021-07-09  发布在  Spark
关注(0)|答案(0)|浏览(259)

我试图执行git repo上提供的异常检测算法
https://github.com/sansa-stack/archived-sansa-examples/blob/master/sansa-examples-spark/src/main/scala/net/sansa_stack/examples/spark/ml/outliers/anomalydetection/anomalydetection.scala
以下代码截取抛出错误。

val setData = clusterOfSubject.repartition(1000).persist(StorageLevel.MEMORY_AND_DISK)
val setDataStore = setData.map(f => f.toSeq)

val setDataSize = setDataStore.filter(f => f.size > anomalyListLimit)

val test = setDataSize.map(f => outDetection.iqr2(f, anomalyListLimit))

但是,当程序计算iqr时,我得到以下错误。我知道我们需要把set换成seq。由于我是scala新手,我不知道如何更改数据类型。toseq函数已应用于所有数据点。
:154:错误:类型不匹配;找到:set[(string,string,object)]必需:seq[(string,string,object)]val test=clusterofsubject.map(f=>outdetection.iqr2(f,anomalylistlimit))

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题