Package org.rumbledb.runtime.plan

Interface RDDRuntimePlan<T>

Type Parameters:
T - the RDD element type
All Known Implementing Classes:
ApplyFunctionIterator, ArrayDescendantFunctionIterator, ArrayFlattenFunctionIterator, ArrayLookupIterator, ArrayMembersFunctionIterator, ArrayUnboxingIterator, BuiltinFunctionItemCallIterator, CommaExpressionIterator, ConstantRDDRuntimeIterator, DataFunctionIterator, DistinctValuesFunctionIterator, DynamicFunctionCallIterator, ExitStatementIterator, FunctionCoercionRuntimeIterator, FunctionItemCallIterator, FunctionUntypedAtomicCastIterator, IfRuntimeIterator, IndexOfFunctionIterator, InsertBeforeFunctionIterator, JSONiqValidateIterator, JsonLinesFunctionIterator, NodeSetOperationIterator, ObjectDescendantFunctionIterator, ObjectKeysFunctionIterator, ObjectLookupIterator, ObjectProjectFunctionIterator, ObjectRemoveKeysFunctionIterator, ObjectValuesFunctionIterator, OneOrMoreIterator, ParallelizeFunctionIterator, PostfixLookupIterator, PredicateIterator, ProgramIterator, RemoveFunctionIterator, RepartitionFunctionIterator, ReturnClauseIterator, ReverseFunctionIterator, SimpleMapExpressionIterator, SlashExprIterator, StatementsWithExprIterator, StaticUserDefinedFunctionCallIterator, SubsequenceFunctionIterator, SwitchRuntimeIterator, TailFunctionIterator, TextFileFunctionIterator, TransformExpressionIterator, TreatIterator, TypePromotionIterator, TypeswitchRuntimeIterator, UnorderedFunctionIterator, UnparsedTextLinesFunctionIterator, VariableReferenceIterator, XmlFilesFunctionIterator
public interface RDDRuntimePlan<T>
Native RDD execution capability. Plans that do not implement this interface are converted centrally from another supported representation.

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.spark.api.java.JavaRDD<T>
    createNativeRDD(DynamicContext context)
    Builds the RDD for one evaluation.

  • Method Details

    • createNativeRDD

      org.apache.spark.api.java.JavaRDD<T> createNativeRDD(DynamicContext context)
      Builds the RDD for one evaluation.
      Parameters:
      context - the dynamic context for that evaluation
      Returns:
      the resulting RDD