User Tools
Site Tools
en:site:recherche:logiciels:sparqlwithspark:chain4
Differences
This shows you the differences between two versions of the page.
| Next revision | Previous revision | ||
|
en:site:recherche:logiciels:sparqlwithspark:chain4 [13/09/2016 22:51] hubert created |
en:site:recherche:logiciels:sparqlwithspark:chain4 [16/09/2016 23:10] (current) hubert [Chain4 query plans] |
||
|---|---|---|---|
| Line 1: | Line 1: | ||
| - | ====== Chain4 query====== | + | {{indexmenu_n>6}} |
| + | |||
| + | |||
| + | ====== Chain4 query plans====== | ||
| The plans produced by each method are: | The plans produced by each method are: | ||
| * SPARQL RDD: | * SPARQL RDD: | ||
| - | <code> | + | |
| - | val d1 = triples.filter{case(s,(p,o))=> p==1389363200}.map{case(x1,(p, x2)) => (x2, x1)} | + | <code scala> |
| + | val d1 = triples.filter{case(s,(p,o))=> p==P1}.map{case(x1,(p, x2)) => (x2, x1)} | ||
| val d2 = triples.filter{case(s,(p,o))=> p==P2}.mapValues{case(p,x3) => x3} | val d2 = triples.filter{case(s,(p,o))=> p==P2}.mapValues{case(p,x3) => x3} | ||
| val d3 = triples.filter{case(s,(p,o))=> p==P3}.mapValues{case(p,x4) => x4} | val d3 = triples.filter{case(s,(p,o))=> p==P3}.mapValues{case(p,x4) => x4} | ||
| Line 16: | Line 20: | ||
| * SPARQL DF: | * SPARQL DF: | ||
| - | <code> | + | <code scala> |
| val t1 = df.where(s"p=$P1").select("s","o").withColumnRenamed("s", "x1").withColumnRenamed("o", "x2") | val t1 = df.where(s"p=$P1").select("s","o").withColumnRenamed("s", "x1").withColumnRenamed("o", "x2") | ||
| val t2 = df.where(s"p=$P2").select("s","o").withColumnRenamed("s", "x2").withColumnRenamed("o", "x3") | val t2 = df.where(s"p=$P2").select("s","o").withColumnRenamed("s", "x2").withColumnRenamed("o", "x3") | ||
| Line 25: | Line 29: | ||
| * SPARQL Hybrid DF: | * SPARQL Hybrid DF: | ||
| - | <code> | + | <code scala> |
| - | val P2 = 52239 | + | |
| - | val P3 = 1164541952 | + | |
| - | val P4 = 1164156928 | + | |
| val subg = df.where(s"p in ($P2, $P3, $P4)") | val subg = df.where(s"p in ($P2, $P3, $P4)") | ||
| subg.persist | subg.persist | ||
| Line 39: | Line 40: | ||
| </code> | </code> | ||
| + | Go to [[en:site:recherche:logiciels:sparqlwithspark]] | ||
en/site/recherche/logiciels/sparqlwithspark/chain4.1473799863.txt.gz · Last modified: 13/09/2016 22:51 by hubert
Page Tools
Except where otherwise noted, content on this wiki is licensed under the following license: CC Attribution-Noncommercial-Share Alike 3.0 Unported
