net.sansa_stack.query.spark.sparqlify

Class ResultSetSparkImpl

java.lang.Object

net.sansa_stack.query.spark.sparqlify.ResultSetSparkImpl

All Implemented Interfaces:

JavaResultSetSpark

public class ResultSetSparkImpl
extends Object
implements JavaResultSetSpark

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.spark.api.java.JavaRDD<org.apache.jena.sparql.engine.binding.Binding>	rdd
protected List<org.apache.jena.sparql.core.Var>	resultVars

Constructor Summary

Constructors

Constructor and Description
ResultSetSparkImpl(List<org.apache.jena.sparql.core.Var> resultVars, org.apache.spark.api.java.JavaRDD<org.apache.jena.sparql.engine.binding.Binding> rdd)

Method Summary

Modifier and Type	Method and Description
org.apache.spark.api.java.JavaRDD<org.apache.jena.sparql.engine.binding.Binding>	getRdd()
List<org.apache.jena.sparql.core.Var>	getResultVars()

Methods inherited from class java.lang.Object

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

Field Detail

resultVars

protected List<org.apache.jena.sparql.core.Var> resultVars

rdd

protected org.apache.spark.api.java.JavaRDD<org.apache.jena.sparql.engine.binding.Binding> rdd

Constructor Detail

ResultSetSparkImpl

public ResultSetSparkImpl(List<org.apache.jena.sparql.core.Var> resultVars,
                          org.apache.spark.api.java.JavaRDD<org.apache.jena.sparql.engine.binding.Binding> rdd)

Method Detail

getResultVars

public List<org.apache.jena.sparql.core.Var> getResultVars()

Specified by:

getResultVars in interface JavaResultSetSpark

getRdd

public org.apache.spark.api.java.JavaRDD<org.apache.jena.sparql.engine.binding.Binding> getRdd()

Specified by:

getRdd in interface JavaResultSetSpark