net.sansa_stack.query.spark.api.impl

Class JavaQueryExecutionSparkBase

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

All Implemented Interfaces:

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

Direct Known Subclasses:

JavaQueryExecutionSparkSparqlify

public abstract class JavaQueryExecutionSparkBase
extends org.aksw.jena_sparql_api.core.QueryExecutionBaseSelect
implements JavaQueryExecutionSpark

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.spark.sql.SparkSession	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
JavaQueryExecutionSparkBase(org.apache.jena.query.Query query, org.aksw.jena_sparql_api.core.QueryExecutionFactory subFactory, org.apache.spark.sql.SparkSession sparkSession)

Method Summary

Modifier and Type	Method and Description
org.apache.spark.api.java.JavaRDD<org.apache.jena.sparql.core.Quad>	execConstructQuadsSparkJava()
org.apache.spark.api.java.JavaRDD<org.apache.jena.graph.Triple>	execConstructSparkJava()
org.apache.jena.atlas.json.JsonArray	execJson()
Iterator<org.apache.jena.atlas.json.JsonObject>	execJsonItems()
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)
long	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 net.sansa_stack.query.spark.api.domain.JavaQueryExecutionSpark

execSelectSparkJava

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

sparkSession

protected org.apache.spark.sql.SparkSession sparkSession

Constructor Detail

JavaQueryExecutionSparkBase

public JavaQueryExecutionSparkBase(org.apache.jena.query.Query query,
                                   org.aksw.jena_sparql_api.core.QueryExecutionFactory subFactory,
                                   org.apache.spark.sql.SparkSession sparkSession)

Method Detail

execConstructSparkJava

public org.apache.spark.api.java.JavaRDD<org.apache.jena.graph.Triple> execConstructSparkJava()

Specified by:

execConstructSparkJava in interface JavaQueryExecutionSpark

execConstructQuadsSparkJava

public org.apache.spark.api.java.JavaRDD<org.apache.jena.sparql.core.Quad> execConstructQuadsSparkJava()

Specified by:

execConstructQuadsSparkJava in interface JavaQueryExecutionSpark

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

getTimeout1

public long getTimeout1()

Specified by:

getTimeout1 in interface org.apache.jena.query.QueryExecution

Overrides:

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

execJson

public org.apache.jena.atlas.json.JsonArray execJson()

Specified by:

execJson in interface org.apache.jena.query.QueryExecution

Overrides:

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

execJsonItems

public Iterator<org.apache.jena.atlas.json.JsonObject> execJsonItems()

Specified by:

execJsonItems in interface org.apache.jena.query.QueryExecution

Overrides:

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