Uses of Class
org.rumbledb.runtime.flwor.FlworDataFrame

Packages that use FlworDataFrame

Package	Description
org.rumbledb.runtime
org.rumbledb.runtime.flwor
org.rumbledb.runtime.flwor.clauses

Uses of FlworDataFrame in org.rumbledb.runtime

Methods in org.rumbledb.runtime that return FlworDataFrame

Modifier and Type	Method	Description
abstract FlworDataFrame	RuntimeTupleIterator.getDataFrame(DynamicContext context)	Obtains the dataframe from the child clause.

Uses of FlworDataFrame in org.rumbledb.runtime.flwor

Methods in org.rumbledb.runtime.flwor that return FlworDataFrame

Modifier and Type	Method	Description
FlworDataFrame	FlworDataFrame.sql(String sqlQuery)

Uses of FlworDataFrame in org.rumbledb.runtime.flwor.clauses

Methods in org.rumbledb.runtime.flwor.clauses that return FlworDataFrame

Modifier and Type	Method	Description
FlworDataFrame	CountClauseSparkIterator.getDataFrame(DynamicContext context)
FlworDataFrame	ForClauseSparkIterator.getDataFrame(DynamicContext context)
FlworDataFrame	GroupByClauseSparkIterator.getDataFrame(DynamicContext context)
FlworDataFrame	JoinClauseSparkIterator.getDataFrame(DynamicContext context)
FlworDataFrame	LetClauseSparkIterator.getDataFrame(DynamicContext context)
FlworDataFrame	OrderByClauseSparkIterator.getDataFrame(DynamicContext context)
FlworDataFrame	WhereClauseSparkIterator.getDataFrame(DynamicContext context)
FlworDataFrame	LetClauseSparkIterator.getDataFrameAsJoin(DynamicContext context, Map<Name,DynamicContext.VariableDependency> parentProjection, FlworDataFrame childDF)
static FlworDataFrame	ForClauseSparkIterator.getDataFrameStartingClause(RuntimeIterator iterator, Name variableName, Name positionalVariableName, boolean allowingEmpty, DynamicContext context, Map<Name,DynamicContext.VariableDependency> outputDependencies)	Starting clause and the expression is parallelizable.
static FlworDataFrame	JoinClauseSparkIterator.joinInputTupleWithSequenceOnPredicate(DynamicContext context, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> leftInputTuple, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> rightInputTuple, Map<Name,DynamicContext.VariableDependency> outputTupleVariableDependencies, List<Name> variablesInLeftInputTuple, List<Name> variablesInRightInputTuple, RuntimeIterator predicateIterator, boolean isLeftOuterJoin, Name newRightSideVariableName, ExceptionMetadata metadata, RumbleRuntimeConfiguration conf)	Joins two input tuples.
static FlworDataFrame	ForClauseSparkIterator.tryNativeQuery(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame, Name newVariableName, Name positionalVariableName, boolean allowingEmpty, RuntimeIterator iterator, List<FlworDataFrameColumn> allColumns, org.apache.spark.sql.types.StructType inputSchema, DynamicContext context)	Try to generate the native query for the for clause and run it, if successful return the resulting dataframe, otherwise it returns null
static FlworDataFrame	OrderByClauseSparkIterator.tryNativeQuery(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame, List<OrderByClauseAnnotatedChildIterator> expressionsWithIterator, List<FlworDataFrameColumn> allColumns, org.apache.spark.sql.types.StructType inputSchema, DynamicContext context)	Try to generate the native query for the order by clause and run it, if successful return the resulting dataframe, otherwise it returns null
static FlworDataFrame	WhereClauseSparkIterator.tryNativeQuery(FlworDataFrame dataFrame, RuntimeIterator iterator, DynamicContext context, ExceptionMetadata metadata)	Try to generate the native query for the let clause and run it, if successful return the resulting dataframe, otherwise it returns null

Methods in org.rumbledb.runtime.flwor.clauses with parameters of type FlworDataFrame

Modifier and Type	Method	Description
FlworDataFrame	LetClauseSparkIterator.getDataFrameAsJoin(DynamicContext context, Map<Name,DynamicContext.VariableDependency> parentProjection, FlworDataFrame childDF)
static FlworDataFrame	WhereClauseSparkIterator.tryNativeQuery(FlworDataFrame dataFrame, RuntimeIterator iterator, DynamicContext context, ExceptionMetadata metadata)	Try to generate the native query for the let clause and run it, if successful return the resulting dataframe, otherwise it returns null