public class SparkRowMapperSparqlify extends Object implements org.apache.spark.api.java.function.Function<org.apache.spark.sql.Row,org.apache.jena.sparql.engine.binding.Binding>, Serializable
Modifier and Type | Field and Description |
---|---|
protected com.google.common.collect.Multimap<org.apache.jena.sparql.core.Var,org.aksw.jena_sparql_api.views.RestrictedExpr> |
varDef |
Constructor and Description |
---|
SparkRowMapperSparqlify(com.google.common.collect.Multimap<org.apache.jena.sparql.core.Var,org.aksw.jena_sparql_api.views.RestrictedExpr> varDef) |
Modifier and Type | Method and Description |
---|---|
org.apache.jena.sparql.engine.binding.Binding |
call(org.apache.spark.sql.Row row) |
static org.apache.jena.sparql.engine.binding.Binding |
rowToRawBinding(org.apache.spark.sql.Row row) |
protected com.google.common.collect.Multimap<org.apache.jena.sparql.core.Var,org.aksw.jena_sparql_api.views.RestrictedExpr> varDef
public SparkRowMapperSparqlify(com.google.common.collect.Multimap<org.apache.jena.sparql.core.Var,org.aksw.jena_sparql_api.views.RestrictedExpr> varDef)
public org.apache.jena.sparql.engine.binding.Binding call(org.apache.spark.sql.Row row)
call
in interface org.apache.spark.api.java.function.Function<org.apache.spark.sql.Row,org.apache.jena.sparql.engine.binding.Binding>
public static org.apache.jena.sparql.engine.binding.Binding rowToRawBinding(org.apache.spark.sql.Row row)
Copyright © 2016–2021 Smart Data Analytics (SDA) Research Group. All rights reserved.