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

Packages that use FlworDataFrame

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

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	CountClauseIterator.createNativeDataFrame(DynamicContext context)
FlworDataFrame	ForClauseIterator.createNativeDataFrame(DynamicContext context)
FlworDataFrame	GroupByClauseIterator.createNativeDataFrame(DynamicContext context)
FlworDataFrame	JoinClauseIterator.createNativeDataFrame(DynamicContext context)
FlworDataFrame	LetClauseIterator.createNativeDataFrame(DynamicContext context)
FlworDataFrame	OrderByClauseIterator.createNativeDataFrame(DynamicContext context)
FlworDataFrame	WhereClauseIterator.createNativeDataFrame(DynamicContext context)
FlworDataFrame	LetClauseIterator.getDataFrameAsJoin(DynamicContext context, Map<Name,DynamicContext.VariableDependency> parentProjection, FlworDataFrame childDF)
static FlworDataFrame	ForClauseIterator.getDataFrameStartingClause(ItemRuntimePlan iterator, Name variableName, Name positionalVariableName, boolean allowingEmpty, DynamicContext context, Map<Name,DynamicContext.VariableDependency> outputDependencies)	Starting clause and the expression is parallelizable.
static FlworDataFrame	JoinClauseIterator.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, ItemRuntimePlan predicateIterator, boolean isLeftOuterJoin, Name newRightSideVariableName, ExceptionMetadata metadata, RuntimeStaticContext staticContext)	Joins two input tuples.
static FlworDataFrame	ForClauseIterator.tryNativeQuery(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame, Name newVariableName, Name positionalVariableName, boolean allowingEmpty, ItemRuntimePlan 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	OrderByClauseIterator.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	WhereClauseIterator.tryNativeQuery(FlworDataFrame dataFrame, ItemRuntimePlan 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	LetClauseIterator.getDataFrameAsJoin(DynamicContext context, Map<Name,DynamicContext.VariableDependency> parentProjection, FlworDataFrame childDF)
static FlworDataFrame	WhereClauseIterator.tryNativeQuery(FlworDataFrame dataFrame, ItemRuntimePlan 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