class OntopSPARQLEngine extends AnyRef
A SPARQL engine based on Ontop as SPARQL-to-SQL rewriter.
- Alphabetic
- By Inheritance
- OntopSPARQLEngine
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
-
new
OntopSPARQLEngine(spark: SparkSession, databaseName: String, partitions: Set[RdfPartitionComplex], ontology: Option[OWLOntology])
- spark
the Spark session
- databaseName
an existing Spark database that contains the tables for the RDF partitions
- partitions
the RDF partitions
- ontology
an (optional) ontology that will be used for query optimization and rewriting
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
- val blankNodeStrategy: BlankNodeStrategy.Value
-
def
clear(): Unit
Free resources, e.g.
Free resources, e.g. unregister Spark tables.
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
- val databaseName: String
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
execAsk(query: String): Boolean
Executes an ASK query on the provided dataset partitions.
Executes an ASK query on the provided dataset partitions.
- query
the SPARQL query
- returns
true
orfalse
depending on the result of the ASK query execution
- Exceptions thrown
org.apache.spark.sql.AnalysisException
if the query execution fails
-
def
execConstruct(query: String): RDD[Triple]
Executes a CONSTRUCT query on the provided dataset partitions.
Executes a CONSTRUCT query on the provided dataset partitions.
- query
the SPARQL query
- returns
an RDD of triples
- Exceptions thrown
org.apache.spark.sql.AnalysisException
if the query execution fails
-
def
execSelect(query: String): RDD[Binding]
Executes a SELECT query on the provided dataset partitions and returns a DataFrame.
Executes a SELECT query on the provided dataset partitions and returns a DataFrame.
- query
the SPARQL query
- returns
an RDD of solution bindings
- Exceptions thrown
org.apache.spark.sql.AnalysisException
if the query execution fails
-
def
execute(query: String): DataFrame
Executes the given SPARQL query on the provided dataset partitions.
Executes the given SPARQL query on the provided dataset partitions.
- query
the SPARQL query
- returns
a DataFrame with the resulting bindings as columns
- Exceptions thrown
org.apache.spark.sql.AnalysisException
if the query execution fails
-
def
executeDebug(query: String): (DataFrame, Option[OntopQueryRewrite])
Executes the given SPARQL query on the provided dataset partitions.
Executes the given SPARQL query on the provided dataset partitions.
- query
the SPARQL query
- returns
a DataFrame with the raw result of the SQL query execution and the query rewrite object for processing the intermediate SQL rows (None if the SQL query was empty)
- Exceptions thrown
org.apache.spark.sql.AnalysisException
if the query execution fails
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- var ontology: Option[OWLOntology]
- val partitions: Set[RdfPartitionComplex]
- val rdfDatatype2SQLCastName: Map[RDFDatatype, DataType]
- val spark: SparkSession
-
def
stop(): Unit
Shutdown of the engine, i.e.
Shutdown of the engine, i.e. all open resource will be closed.
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
- val typeFactory: TypeFactory
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()