public abstract class JavaQueryExecutionSparkBase extends org.aksw.jena_sparql_api.core.QueryExecutionBaseSelect implements JavaQueryExecutionSpark
Modifier and Type | Field and Description |
---|---|
protected org.apache.spark.sql.SparkSession |
sparkSession |
Constructor and Description |
---|
JavaQueryExecutionSparkBase(org.apache.jena.query.Query query,
org.aksw.jena_sparql_api.core.QueryExecutionFactory subFactory,
org.apache.spark.sql.SparkSession sparkSession) |
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() |
createModel, createModel, execAsk, execConstruct, execConstruct, execConstructTriples, execDescribe, execDescribe, execDescribeTriples, execSelect, executeConstructStreaming, executeUpdate, extractDescribeNode, getQuery
abort, afterExec, beforeExec, close, execConstructDataset, execConstructDataset, execConstructQuads, getContext, getDataset, getDecoratee, getTimeout2, isClosed, onException, setInitialBinding, setInitialBinding, setTimeout, setTimeout, setTimeout, setTimeout, unwrap, unwrap
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
execSelectSparkJava
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
public JavaQueryExecutionSparkBase(org.apache.jena.query.Query query, org.aksw.jena_sparql_api.core.QueryExecutionFactory subFactory, org.apache.spark.sql.SparkSession sparkSession)
public org.apache.spark.api.java.JavaRDD<org.apache.jena.graph.Triple> execConstructSparkJava()
execConstructSparkJava
in interface JavaQueryExecutionSpark
public org.apache.spark.api.java.JavaRDD<org.apache.jena.sparql.core.Quad> execConstructQuadsSparkJava()
execConstructQuadsSparkJava
in interface JavaQueryExecutionSpark
protected org.aksw.jena_sparql_api.core.ResultSetCloseable executeCoreSelect(org.apache.jena.query.Query query)
executeCoreSelect
in class org.aksw.jena_sparql_api.core.QueryExecutionBaseSelect
protected org.apache.jena.query.QueryExecution executeCoreSelectX(org.apache.jena.query.Query query)
executeCoreSelectX
in class org.aksw.jena_sparql_api.core.QueryExecutionBaseSelect
public long getTimeout1()
getTimeout1
in interface org.apache.jena.query.QueryExecution
getTimeout1
in class org.aksw.jena_sparql_api.core.QueryExecutionDecoratorBase<org.apache.jena.query.QueryExecution>
public org.apache.jena.atlas.json.JsonArray execJson()
execJson
in interface org.apache.jena.query.QueryExecution
execJson
in class org.aksw.jena_sparql_api.core.QueryExecutionBaseSelect
public Iterator<org.apache.jena.atlas.json.JsonObject> execJsonItems()
execJsonItems
in interface org.apache.jena.query.QueryExecution
execJsonItems
in class org.aksw.jena_sparql_api.core.QueryExecutionBaseSelect
Copyright © 2016–2021 Smart Data Analytics (SDA) Research Group. All rights reserved.