问题标签 [sansa]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
1 回答
482 浏览

scala - 为什么 Spark 失败并显示“值 rdf 不是 org.apache.spark.sql.SparkSession 的成员”?

我正在尝试使用SANSA-RDF将海龟 RDF 文件读入 Spark 并创建一个图形。执行以下代码时出现错误。我错过了什么?

我正在使用主函数调用 SparkExecutor

这会导致以下错误

0 投票
0 回答
108 浏览

apache-spark - 是否可以在 PySpark 中使用 SANSA-RDF 和 SANSA-Query?

我计划使用SANSA-RDF 将turtle RDF/XML 文件读入Spark 并使用SANSA-Query 库进行查询。是否可以使用这些库开发 PySpark (python) 代码?是否有任何 PySpark (python) 示例?

提前致谢..

0 投票
0 回答
204 浏览

scala - 运行 SANSA-Stack/SANSA-Examples 时无法初始化类 org.apache.jena.riot.system.RiotLib 错误

我正在尝试在 SANSA-Stack/SANSA-Examples ( https://github.com/SANSA-Stack/SANSA-Examples )中运行 SilviaClusteringExample

我已经使用具有一个主节点和 3 个工作节点的 GCP DataProc 设置了 Spark 集群。按照给出的说明,通过为--input&--output路径指定 Hadoop 文件系统文件路径来运行 spark-submit。

运行以下命令,

上面的命令返回以下错误,

Hadoop文件系统下的文件,

请帮助解决上述问题。谢谢。

0 投票
1 回答
51 浏览

rdf - 基于多个主题查找三元组 (SANSA-STACK)

我有一个使用主题查找 Triples 的代码,所以我使用 Triple 的 find 方法并提供如下必要的:

但是如何找到可以传递多个主题节点的结果?

0 投票
0 回答
69 浏览

sparql - sparql 中 BIND 方法的替代方法

我正在使用Sansa 堆栈对 HDFS 中的大量数据执行 sparql 查询。Sansa 是一个基于 spark 的框架,可对大量数据执行 sparql 查询。我的 sparql 查询中有如下分配。

但是 sansa 无法进行这种转换,并且最终输出没有变量 ?docid 。sparql 中是否还有其他类似于 BIND 的功能?

0 投票
1 回答
342 浏览

apache-spark - SANSA 出错,无法从 NT 文件创建 RDD

无法使用创建 RDD[Triple]

习惯于在 Java 11 和 Spark 2.4.x 上正常工作

不工作,使用 Java 8 和 Spark 3.0 时抛出错误


0 投票
0 回答
18 浏览

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

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

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

但是,当程序计算 IQR 时出现以下错误。我知道我们需要用 seq 替换 set。由于我是 scala 的新手,我不知道如何更改数据类型。toSeq 函数已应用于所有数据点。

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