net.sansa_stack.query.spark.sparqlify

Class JavaQueryExecutionSparkSparqlify

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.query.spark.api.impl.JavaQueryExecutionSparkBase

net.sansa_stack.query.spark.sparqlify.JavaQueryExecutionSparkSparqlify

All Implemented Interfaces:

AutoCloseable, JavaQueryExecutionSpark, org.apache.jena.query.QueryExecution

public class JavaQueryExecutionSparkSparqlify
extends JavaQueryExecutionSparkBase

Field Summary

Fields

Modifier and Type	Field and Description
protected org.aksw.sparqlify.core.interfaces.SparqlSqlStringRewriter	sparqlSqlRewriter

Fields inherited from class net.sansa_stack.query.spark.api.impl.JavaQueryExecutionSparkBase

sparkSession

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
JavaQueryExecutionSparkSparqlify(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
JavaResultSetSpark	execSelectSparkJava()

Methods inherited from class net.sansa_stack.query.spark.api.impl.JavaQueryExecutionSparkBase

execConstructQuadsSparkJava, execConstructSparkJava, execJson, execJsonItems, executeCoreSelect, executeCoreSelectX, getTimeout1

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

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

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

abort, afterExec, beforeExec, close, execConstructDataset, execConstructDataset, execConstructQuads, getContext, getDataset, getDecoratee, getTimeout2, isClosed, onException, setInitialBinding, setInitialBinding, setTimeout, setTimeout, setTimeout, setTimeout, unwrap, unwrap

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, create, execAsk, execConstruct, execConstruct, execConstructDataset, execConstructDataset, execConstructQuads, execConstructTriples, execDescribe, execDescribe, execDescribeTriples, execSelect, getContext, getDataset, getQuery, getTimeout2, isClosed, setInitialBinding, setInitialBinding, setTimeout, setTimeout, setTimeout, setTimeout

Field Detail

sparqlSqlRewriter

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

Constructor Detail

JavaQueryExecutionSparkSparqlify

public JavaQueryExecutionSparkSparqlify(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

execSelectSparkJava

public JavaResultSetSpark execSelectSparkJava()