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 voidDynamicContext.mergeVariableDependencies(Map<Name, DynamicContext.VariableDependency> into, Map<Name, DynamicContext.VariableDependency> from) static voidDynamicContext.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.inputTupleProjectionprotected Map<Name,DynamicContext.VariableDependency> RuntimeTupleIterator.outputTupleProjectionMethods 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.voidRuntimeTupleIterator.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 voidFlworDataFrameUtils.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 StringFlworDataFrameUtils.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 FlworDataFrameForClauseSparkIterator.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 FlworDataFrameJoinClauseSparkIterator.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()