Package org.rumbledb.runtime.flwor

Class FlworDataFrame

java.lang.Object

org.rumbledb.runtime.flwor.FlworDataFrame

All Implemented Interfaces:

Serializable, RuntimeDataFrame<FlworTuple>

public class FlworDataFrame
extends Object
implements RuntimeDataFrame<FlworTuple>, Serializable

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
FlworDataFrame(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame)

Method Summary

Modifier and Type	Method	Description
String	createTempView()
List<FlworDataFrameColumn>	getColumns(Map<Name,DynamicContext.VariableDependency> dependencies, List<Name> variablesToRestrictTo, List<Name> variablesToExclude)
org.apache.spark.sql.UDFRegistration	getUDFRegistration()
List<Name>	getVariableNames()
SequenceType	getVariableType(Name name)
boolean	hasVariableName(Name name)
void	setVariableType(Name name, SequenceType type)
void	show()
FlworDataFrame	sql(String sqlQuery)
org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>	sqlRaw(String sqlQuery)
org.apache.spark.api.java.JavaRDD<FlworTuple>	toRDD(ExceptionMetadata metadata)	Converts this DataFrame to its logical runtime representation.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.rumbledb.runtime.dataframe.RuntimeDataFrame

getDataFrame, toList

Constructor Details

FlworDataFrame

public FlworDataFrame(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame)

Method Details

toRDD

public org.apache.spark.api.java.JavaRDD<FlworTuple> toRDD(ExceptionMetadata metadata)

Description copied from interface: RuntimeDataFrame

Converts this DataFrame to its logical runtime representation.

Specified by:

toRDD in interface RuntimeDataFrame<FlworTuple>

Parameters:

metadata - query metadata used if a row cannot be decoded

Returns:

an RDD of logical runtime values

getVariableNames

public List<Name> getVariableNames()

hasVariableName

public boolean hasVariableName(Name name)

getUDFRegistration

public org.apache.spark.sql.UDFRegistration getUDFRegistration()

sql

public FlworDataFrame sql(String sqlQuery)

sqlRaw

public org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> sqlRaw(String sqlQuery)

getColumns

public List<FlworDataFrameColumn> getColumns(Map<Name,DynamicContext.VariableDependency> dependencies,
 List<Name> variablesToRestrictTo,
 List<Name> variablesToExclude)

setVariableType

public void setVariableType(Name name,
 SequenceType type)

getVariableType

public SequenceType getVariableType(Name name)

createTempView

public String createTempView()

show

public void show()