Bases de Données / Databases

Site Web de l'équipe BD du LIP6 / LIP6 DB Web Site

User Tools

Site Tools

Trace:
en:site:recherche:logiciels:sparqlwithspark:chain4

Differences

This shows you the differences between two versions of the page.

Link to this comparison view

Both sides previous revisionPrevious revision
Next revision		Previous revision
en:site:recherche:logiciels:sparqlwithspark:chain4 [15/09/2016 10:11] – huberten:site:recherche:logiciels:sparqlwithspark:chain4 [16/09/2016 23:10] (current) – [Chain4 query plans] hubert
Line 1: Line 1:
-{{indexmenu_n>3}}+{{indexmenu_n>6}}
  
  
-====== Chain4 query======+====== Chain4 query plans======
  
 The plans produced by each method are: The plans produced by each method are:
   * SPARQL RDD:   * SPARQL RDD:
-<code>+ 
 +<code scala>
 val d1 = triples.filter{case(s,(p,o))=> p==P1}.map{case(x1,(p, x2)) => (x2, x1)} 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}
Line 19: 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 28: Line 29:
  
   * SPARQL Hybrid DF:   * SPARQL Hybrid DF:
-<code>+<code scala>
 val subg = df.where(s"p in ($P2, $P3, $P4)") val subg = df.where(s"p in ($P2, $P3, $P4)")
 subg.persist subg.persist
en/site/recherche/logiciels/sparqlwithspark/chain4.1473927090.txt.gz · Last modified: by hubert