scala - SANSA 堆栈上的 Scala 异常检测

Question

我试图执行 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。斯卡拉

以下代码片段会引发错误。

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 时出现以下错误。我知道我们需要用 seq 替换 set。由于我是 scala 的新手，我不知道如何更改数据类型。toSeq 函数已应用于所有数据点。

:154: 错误：类型不匹配；找到：Set[(String, String, Object)] 需要：Seq[(String, String, Object)] val test = clusterOfSubject.map(f => outDetection.iqr2(f, anomalyListLimit))