Ci-dessous, les différences entre deux révisions de la page.
Les deux révisions précédentes Révision précédente Prochaine révision | Révision précédente | ||
site:recherche:logiciels:rdfdist [11/05/2015 16:51] amine [Graph partitioning-based approaches] |
site:recherche:logiciels:rdfdist [26/04/2017 13:06] amann |
||
---|---|---|---|
Ligne 1: | Ligne 1: | ||
- | ===== RDFdist ===== | + | {{indexmenu_n>1}} |
+ | |||
+ | ===== RDFdist : RDF distribution approaches using Spark ===== | ||
This wiki page provides information about the experiments RDF distribution approaches using [[http://spark.apache.org/|Spark]]. | This wiki page provides information about the experiments RDF distribution approaches using [[http://spark.apache.org/|Spark]]. | ||
Ligne 11: | Ligne 13: | ||
We also created two queries for the [[https://www.wikidata.org/wiki/Wikidata:Main_Page|Wikidata]] dataset which are referred to as Query 5 and Query 6. | We also created two queries for the [[https://www.wikidata.org/wiki/Wikidata:Main_Page|Wikidata]] dataset which are referred to as Query 5 and Query 6. | ||
- | ===Query 1 (synthetic, LUMB)=== | + | ===Query 1 (synthetic, LUBM)=== |
<code> | <code> | ||
SELECT ?x ?y ?z | SELECT ?x ?y ?z | ||
Ligne 154: | Ligne 156: | ||
val takco : Long = 1115684864 | val takco : Long = 1115684864 | ||
- | def ajout(a : ListBuffer[(Long, Long, Long)], e: (Long, Long, Long) ) : ListBuffer[(Long, Long, Long)] = { | ||
- | a += e | ||
- | return a | ||
- | } | ||
// ----------------------------------------------------------- | // ----------------------------------------------------------- | ||
Ligne 265: | Ligne 263: | ||
====Graph partitioning-based approaches==== | ====Graph partitioning-based approaches==== | ||
- | ===Hunang Approach === | + | ===Huang Approach === |
<code> | <code> | ||
import org.apache.spark.HashPartitioner | import org.apache.spark.HashPartitioner | ||
Ligne 298: | Ligne 296: | ||
val takco : Long = 1115684864 | val takco : Long = 1115684864 | ||
- | def ajout(a : ListBuffer[(Long, Long, Long)], e: (Long, Long, Long) ) : ListBuffer[(Long, Long, Long)] = { | ||
- | a += e | ||
- | return a | ||
- | } | ||
// ----------------------------------------------------------- | // ----------------------------------------------------------- | ||
Ligne 856: | Ligne 850: | ||
</code> | </code> | ||
- | ===LUBM Univ1 quadruples === | + | ===LUBM Univ1 === |
+ | -[[http://webia.lip6.fr/~baazizi/research/iswc2015eval/sources/univ1_encoded_unique.id|encoded triples]](2.1MB) | ||
+ | |||
+ | -[[http://webia.lip6.fr/~baazizi/research/iswc2015eval/sources/quads_plus_replicas.id|encoded quaruples with replication]](2.3MB) | ||
+ | |||
+ | -[[http://webia.lip6.fr/~baazizi/research/iswc2015eval/sources/quads.id|replicated quaruples]](0.3MB) | ||
+ | |||
+ | -[[http://webia.lip6.fr/~baazizi/research/iswc2015eval/sources/univ1.nt|univ1.nt]] (16.3MB) |