Uses of Enum Class
org.rumbledb.context.DynamicContext.VariableDependency
Packages that use DynamicContext.VariableDependency
Package
Description
-
Uses of DynamicContext.VariableDependency in org.rumbledb.context
Methods in org.rumbledb.context that return DynamicContext.VariableDependencyModifier and TypeMethodDescriptionReturns the enum constant of this class with the specified name.static DynamicContext.VariableDependency[]
DynamicContext.VariableDependency.values()
Returns an array containing the constants of this enum class, in the order they are declared.Methods in org.rumbledb.context that return types with arguments of type DynamicContext.VariableDependencyModifier and TypeMethodDescriptionstatic Map<Name,
DynamicContext.VariableDependency> DynamicContext.copyVariableDependencies
(Map<Name, DynamicContext.VariableDependency> from) Method parameters in org.rumbledb.context with type arguments of type DynamicContext.VariableDependencyModifier and TypeMethodDescriptionstatic Map<Name,
DynamicContext.VariableDependency> DynamicContext.copyVariableDependencies
(Map<Name, DynamicContext.VariableDependency> from) static void
DynamicContext.mergeVariableDependencies
(Map<Name, DynamicContext.VariableDependency> into, Map<Name, DynamicContext.VariableDependency> from) static void
DynamicContext.printDependencies
(Map<Name, DynamicContext.VariableDependency> exprDependency) -
Uses of DynamicContext.VariableDependency in org.rumbledb.runtime
Fields in org.rumbledb.runtime with type parameters of type DynamicContext.VariableDependencyModifier and TypeFieldDescriptionprotected Map<Name,
DynamicContext.VariableDependency> RuntimeTupleIterator.inputTupleProjection
protected Map<Name,
DynamicContext.VariableDependency> RuntimeTupleIterator.outputTupleProjection
Methods in org.rumbledb.runtime that return types with arguments of type DynamicContext.VariableDependencyModifier and TypeMethodDescriptionRuntimeTupleIterator.getDynamicContextVariableDependencies()
Variable dependencies are variables that MUST be provided by the parent clause in the dynamic context for successful execution of this clause.protected abstract Map<Name,
DynamicContext.VariableDependency> RuntimeTupleIterator.getInputTupleVariableDependencies
(Map<Name, DynamicContext.VariableDependency> parentProjection) Builds the DataFrame projection that this clause needs to receive from its child clause.RuntimeIterator.getVariableDependencies()
Method parameters in org.rumbledb.runtime with type arguments of type DynamicContext.VariableDependencyModifier and TypeMethodDescriptionprotected abstract Map<Name,
DynamicContext.VariableDependency> RuntimeTupleIterator.getInputTupleVariableDependencies
(Map<Name, DynamicContext.VariableDependency> parentProjection) Builds the DataFrame projection that this clause needs to receive from its child clause.void
RuntimeTupleIterator.setInputAndOutputTupleVariableDependencies
(Map<Name, DynamicContext.VariableDependency> parentProjection) Computes and stores the DataFrame projection that this clause needs to receive from its child clause. -
Uses of DynamicContext.VariableDependency in org.rumbledb.runtime.flwor
Method parameters in org.rumbledb.runtime.flwor with type arguments of type DynamicContext.VariableDependencyModifier and TypeMethodDescriptionFlworDataFrame.getColumns
(Map<Name, DynamicContext.VariableDependency> dependencies, List<Name> variablesToRestrictTo, List<Name> variablesToExclude) static List<FlworDataFrameColumn>
FlworDataFrameUtils.getColumns
(org.apache.spark.sql.types.StructType inputSchema, Map.Entry<Name, DynamicContext.VariableDependency> dependencies) Lists the names of the columns of the schema that needed by the dependencies.static void
FlworDataFrameUtils.getColumns
(org.apache.spark.sql.types.StructType inputSchema, Map.Entry<Name, DynamicContext.VariableDependency> dependency, List<Name> variablesToRestrictTo, List<Name> variablesToExclude, List<FlworDataFrameColumn> result) Lists the names of the columns of the schema that needed by the dependencies, but except duplicates (which are overriden).static List<FlworDataFrameColumn>
FlworDataFrameUtils.getColumns
(org.apache.spark.sql.types.StructType inputSchema, Map<Name, DynamicContext.VariableDependency> dependencies) Lists the names of the columns of the schema that needed by the dependencies.static List<FlworDataFrameColumn>
FlworDataFrameUtils.getColumns
(org.apache.spark.sql.types.StructType inputSchema, Map<Name, DynamicContext.VariableDependency> dependencies, List<Name> variablesToRestrictTo, List<Name> variablesToExclude) Lists the names of the columns of the schema that needed by the dependencies, but except duplicates (which are overriden).static String
FlworDataFrameUtils.getGroupBySQLProjection
(org.apache.spark.sql.types.StructType inputSchema, int duplicateVariableIndex, boolean trailingComma, String serializerUdfName, List<Name> groupbyVariableNames, Map<Name, DynamicContext.VariableDependency> dependencies) Prepares a SQL projection for use in a GROUP BY query. -
Uses of DynamicContext.VariableDependency in org.rumbledb.runtime.flwor.clauses
Methods in org.rumbledb.runtime.flwor.clauses that return types with arguments of type DynamicContext.VariableDependencyModifier and TypeMethodDescriptionCountClauseSparkIterator.getDynamicContextVariableDependencies()
ForClauseSparkIterator.getDynamicContextVariableDependencies()
GroupByClauseSparkIterator.getDynamicContextVariableDependencies()
LetClauseSparkIterator.getDynamicContextVariableDependencies()
OrderByClauseSparkIterator.getDynamicContextVariableDependencies()
WhereClauseSparkIterator.getDynamicContextVariableDependencies()
CountClauseSparkIterator.getInputTupleVariableDependencies
(Map<Name, DynamicContext.VariableDependency> parentProjection) ForClauseSparkIterator.getInputTupleVariableDependencies
(Map<Name, DynamicContext.VariableDependency> parentProjection) GroupByClauseSparkIterator.getInputTupleVariableDependencies
(Map<Name, DynamicContext.VariableDependency> parentProjection) protected Map<Name,
DynamicContext.VariableDependency> JoinClauseSparkIterator.getInputTupleVariableDependencies
(Map<Name, DynamicContext.VariableDependency> parentProjection) LetClauseSparkIterator.getInputTupleVariableDependencies
(Map<Name, DynamicContext.VariableDependency> parentProjection) OrderByClauseSparkIterator.getInputTupleVariableDependencies
(Map<Name, DynamicContext.VariableDependency> parentProjection) WhereClauseSparkIterator.getInputTupleVariableDependencies
(Map<Name, DynamicContext.VariableDependency> parentProjection) ReturnClauseSparkIterator.getVariableDependencies()
Method parameters in org.rumbledb.runtime.flwor.clauses with type arguments of type DynamicContext.VariableDependencyModifier and TypeMethodDescriptionstatic org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>
CountClauseSparkIterator.addSerializedCountColumn
(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> df, Map<Name, DynamicContext.VariableDependency> outputDependencies, Name variableName) static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>
LetClauseSparkIterator.bindLetVariableInDataFrame
(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame, Name newVariableName, SequenceType sequenceType, RuntimeIterator newVariableExpression, DynamicContext context, List<Name> variablesInInputTuple, Map<Name, DynamicContext.VariableDependency> outputTupleVariableDependencies, boolean hash, RumbleRuntimeConfiguration conf) Extends a DataFrame with a new column obtained from the evaluation of an expression for each tuple.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.CountClauseSparkIterator.getInputTupleVariableDependencies
(Map<Name, DynamicContext.VariableDependency> parentProjection) ForClauseSparkIterator.getInputTupleVariableDependencies
(Map<Name, DynamicContext.VariableDependency> parentProjection) GroupByClauseSparkIterator.getInputTupleVariableDependencies
(Map<Name, DynamicContext.VariableDependency> parentProjection) protected Map<Name,
DynamicContext.VariableDependency> JoinClauseSparkIterator.getInputTupleVariableDependencies
(Map<Name, DynamicContext.VariableDependency> parentProjection) LetClauseSparkIterator.getInputTupleVariableDependencies
(Map<Name, DynamicContext.VariableDependency> parentProjection) OrderByClauseSparkIterator.getInputTupleVariableDependencies
(Map<Name, DynamicContext.VariableDependency> parentProjection) WhereClauseSparkIterator.getInputTupleVariableDependencies
(Map<Name, DynamicContext.VariableDependency> parentProjection) 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. -
Uses of DynamicContext.VariableDependency in org.rumbledb.runtime.flwor.expression
Methods in org.rumbledb.runtime.flwor.expression that return types with arguments of type DynamicContext.VariableDependency -
Uses of DynamicContext.VariableDependency in org.rumbledb.runtime.functions
Methods in org.rumbledb.runtime.functions that return types with arguments of type DynamicContext.VariableDependencyModifier and TypeMethodDescriptionStaticUserDefinedFunctionCallIterator.getVariableDependencies()
-
Uses of DynamicContext.VariableDependency in org.rumbledb.runtime.functions.context
Methods in org.rumbledb.runtime.functions.context that return types with arguments of type DynamicContext.VariableDependencyModifier and TypeMethodDescriptionLastFunctionIterator.getVariableDependencies()
PositionFunctionIterator.getVariableDependencies()
-
Uses of DynamicContext.VariableDependency in org.rumbledb.runtime.functions.sequences.aggregate
Methods in org.rumbledb.runtime.functions.sequences.aggregate that return types with arguments of type DynamicContext.VariableDependencyModifier and TypeMethodDescriptionAvgFunctionIterator.getVariableDependencies()
CountFunctionIterator.getVariableDependencies()
MaxFunctionIterator.getVariableDependencies()
MinFunctionIterator.getVariableDependencies()
SumFunctionIterator.getVariableDependencies()
-
Uses of DynamicContext.VariableDependency in org.rumbledb.runtime.primary
Methods in org.rumbledb.runtime.primary that return types with arguments of type DynamicContext.VariableDependencyModifier and TypeMethodDescriptionContextExpressionIterator.getVariableDependencies()
VariableReferenceIterator.getVariableDependencies()