Как запустить sparql используя jena elephas и spark - PullRequest
0 голосов
/ 04 марта 2019

Я хочу сделать sparql для данных, которые хранятся в формате hdf или данных в переменной rdd, используя jena elephas и spark.

Ниже я попытался прочитать файл rdf и сохранить его в формате rdd.

val factory = new RdfXmlReaderFactory()
HadoopRdfIORegistry.addReaderFactory(factory)
val conf = new Configuration()
conf.set("rdf.io.input.ignore-bad-tuples", "false")
val path = "twitter.rdf"
val data = sc.newAPIHadoopFile(path,
              classOf[RdfXmlInputFormat],
              classOf[LongWritable], 
              classOf[TripleWritable],   
              conf)

Как сделать запрос sparql на вышеуказанные данные?заранее спасибо ..

...