Я хочу сделать 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 на вышеуказанные данные?заранее спасибо ..