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 Les deux révisions suivantes | ||
site:recherche:logiciels:sparqlwithspark [13/09/2016 17:56] hubert [Chain queries] |
site:recherche:logiciels:sparqlwithspark [13/09/2016 17:57] hubert [Chain queries] |
||
---|---|---|---|
Ligne 34: | Ligne 34: | ||
* SPARQL RDD: | * SPARQL RDD: | ||
<code> | <code> | ||
- | val d1 = triples.filter{case(s,(p,o))=> p==1389363200 || p==18843 || p==1089470464 || p==18970 }.map{case(x1,(p, x2))=> (x2, x1)} | + | val d1 = triples.filter{case(s,(p,o))=> p==1389363200}.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} |