net.sansa_stack.rdf.spark.sparqlify

Class QueryExecutionSparqlifySpark

java.lang.Object

org.aksw.jena_sparql_api.core.QueryExecutionDecoratorBase<org.apache.jena.query.QueryExecution>

org.aksw.jena_sparql_api.core.QueryExecutionDecorator

org.aksw.jena_sparql_api.core.QueryExecutionBaseSelect

net.sansa_stack.rdf.spark.sparqlify.QueryExecutionSparqlifySpark

All Implemented Interfaces:

AutoCloseable, org.apache.jena.query.QueryExecution

public class QueryExecutionSparqlifySpark
extends org.aksw.jena_sparql_api.core.QueryExecutionBaseSelect

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.spark.sql.SparkSession	sparkSession
protected org.aksw.sparqlify.core.interfaces.SparqlSqlStringRewriter	sparqlSqlRewriter

Fields inherited from class org.aksw.jena_sparql_api.core.QueryExecutionBaseSelect

parentFactory, query

Fields inherited from class org.aksw.jena_sparql_api.core.QueryExecutionDecoratorBase

decoratee

Constructor Summary

Constructors

Constructor and Description
QueryExecutionSparqlifySpark(org.apache.jena.query.Query query, org.aksw.jena_sparql_api.core.QueryExecutionFactory subFactory, org.apache.spark.sql.SparkSession sparkSession, org.aksw.sparqlify.core.interfaces.SparqlSqlStringRewriter sparqlSqlRewriter)

Method Summary

Modifier and Type	Method and Description
protected org.aksw.jena_sparql_api.core.ResultSetCloseable	executeCoreSelect(org.apache.jena.query.Query query)
protected org.apache.jena.query.QueryExecution	executeCoreSelectX(org.apache.jena.query.Query query)

Methods inherited from class org.aksw.jena_sparql_api.core.QueryExecutionBaseSelect

createModel, createModel, execAsk, execConstruct, execConstruct, execConstructTriples, execDescribe, execDescribe, execDescribeTriples, execSelect, executeUpdate, extractDescribeNode

Methods inherited from class org.aksw.jena_sparql_api.core.QueryExecutionDecoratorBase

abort, afterExec, beforeExec, close, execConstructDataset, execConstructDataset, execConstructQuads, getContext, getDataset, getDecoratee, getQuery, getTimeout1, getTimeout2, isClosed, setInitialBinding, setTimeout, setTimeout, setTimeout, setTimeout

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.jena.query.QueryExecution

abort, close, execConstructDataset, execConstructDataset, execConstructQuads, getContext, getDataset, getQuery, getTimeout1, getTimeout2, isClosed, setInitialBinding, setTimeout, setTimeout, setTimeout, setTimeout

Field Detail

sparkSession

protected org.apache.spark.sql.SparkSession sparkSession

sparqlSqlRewriter

protected org.aksw.sparqlify.core.interfaces.SparqlSqlStringRewriter sparqlSqlRewriter

Constructor Detail

QueryExecutionSparqlifySpark

public QueryExecutionSparqlifySpark(org.apache.jena.query.Query query,
                                    org.aksw.jena_sparql_api.core.QueryExecutionFactory subFactory,
                                    org.apache.spark.sql.SparkSession sparkSession,
                                    org.aksw.sparqlify.core.interfaces.SparqlSqlStringRewriter sparqlSqlRewriter)

Method Detail

executeCoreSelect

protected org.aksw.jena_sparql_api.core.ResultSetCloseable executeCoreSelect(org.apache.jena.query.Query query)

Overrides:

executeCoreSelect in class org.aksw.jena_sparql_api.core.QueryExecutionBaseSelect

executeCoreSelectX

protected org.apache.jena.query.QueryExecution executeCoreSelectX(org.apache.jena.query.Query query)

Specified by:

executeCoreSelectX in class org.aksw.jena_sparql_api.core.QueryExecutionBaseSelect