en:site:recherche:logiciels:sparqlwithspark:utility
Differences
This shows you the differences between two versions of the page.
Both sides previous revisionPrevious revisionNext revision | Previous revision | ||
en:site:recherche:logiciels:sparqlwithspark:utility [15/09/2016 15:37] – hubert | en:site:recherche:logiciels:sparqlwithspark:utility [16/09/2016 23:05] (current) – [Utilities] hubert | ||
---|---|---|---|
Line 6: | Line 6: | ||
=== Data loading utilities=== | === Data loading utilities=== | ||
- | < | + | < |
// TIMER | // TIMER | ||
Line 73: | Line 73: | ||
=== QUERY utilities === | === QUERY utilities === | ||
- | < | + | < |
case class v(n:Int) | case class v(n:Int) | ||
Line 86: | Line 86: | ||
} | } | ||
- | + | // encode | |
- | // encode | + | |
def sparqlEncode(splittedSparql: | def sparqlEncode(splittedSparql: | ||
return splittedSparql.map{ case (s, | return splittedSparql.map{ case (s, | ||
val idP = getIdP(ns, p) | val idP = getIdP(ns, p) | ||
- | (s,o) match { | + | (s, o) match { |
- | case(a:v, b:v)=> (a, idP, b) | + | case(v(a), v(b))=> |
- | case(lit: | + | case(lit: |
- | (idLit, idP, b)} | + | (idLit, idP, v(b))} |
- | case(a:v, | + | case(v(a), lit: |
- | (a, idP, idLit)} | + | |
}}} | }}} | ||
+ | // generate selection operator for each triple pattern | ||
def tpOperators(encodedQuery: | def tpOperators(encodedQuery: | ||
encodedQuery.map{ case(v(a), p, v(b))=> ( (v(a), p, v(b)), d(p).withColumnRenamed(" | encodedQuery.map{ case(v(a), p, v(b))=> ( (v(a), p, v(b)), d(p).withColumnRenamed(" |
en/site/recherche/logiciels/sparqlwithspark/utility.1473946664.txt.gz · Last modified: by hubert