Package org.rumbledb.runtime.plan

Class ItemRuntimePlan

java.lang.Object

org.rumbledb.runtime.plan.RuntimePlan<Item>

org.rumbledb.runtime.plan.ItemRuntimePlan

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

AbstractAtMostOneItemRuntimePlan, AnnotateFunctionIterator, AppendExpressionIterator, ApplyFunctionIterator, ApplyTransformerRuntimeIterator, ArrayDescendantFunctionIterator, ArrayFlattenFunctionIterator, ArrayFoldLeftFunctionIterator, ArrayFoldRightFunctionIterator, ArrayFunctionCallIterator, ArrayGetFunctionIterator, ArrayHeadFunctionIterator, ArrayLookupIterator, ArrayMembersFunctionIterator, ArrayUnboxingIterator, AvroFileFunctionIterator, AxisIterator, BuiltinFunctionItemCallIterator, BuiltinNamedFunctionReferenceMarkerIterator, CollectionFunctionIterator, CommaExpressionIterator, ConstantRDDRuntimeIterator, ConstructorFunctionIterator, CreateCollectionIterator, CSVFileFunctionIterator, DataFunctionIterator, DeleteExpressionIterator, DeleteIndexFromCollectionIterator, DeleteSearchFromCollectionIterator, DeltaFileFunctionIterator, DeltaTableFunctionIterator, DistinctValuesFunctionIterator, DropColumnsIterator, DynamicFunctionCallIterator, EditCollectionIterator, ElementWithIdFunctionIterator, ExitStatementIterator, FilterFunctionIterator, FoldLeftFunctionIterator, FoldRightFunctionIterator, ForEachFunctionIterator, ForEachPairFunctionIterator, FunctionCoercionRuntimeIterator, FunctionItemCallIterator, FunctionUntypedAtomicCastIterator, IcebergTableFunctionIterator, IdFunctionIterator, IdRefFunctionIterator, IfRuntimeIterator, IndexOfFunctionIterator, InnermostFunctionIterator, InsertBeforeFunctionIterator, InsertExpressionIterator, InsertIndexIntoCollectionIterator, InsertSearchIntoCollectionIterator, JSONiqValidateIterator, JsonLinesFunctionIterator, LibSVMFileFunctionIterator, LocalFunctionCallIterator, MapForEachFunctionIterator, MapFunctionCallIterator, MapGetFunctionIterator, MapKeysFunctionIterator, MongoDBCollectionFunctionIterator, NodeSetOperationIterator, ObjectDescendantFunctionIterator, ObjectKeysFunctionIterator, ObjectLookupIterator, ObjectProjectFunctionIterator, ObjectRemoveKeysFunctionIterator, ObjectValuesFunctionIterator, OneOrMoreIterator, OutermostFunctionIterator, ParallelizeFunctionIterator, ParquetFileFunctionIterator, PostfixLookupIterator, PostgreSQLTableFunctionIterator, PredicateIterator, ProgramIterator, RandomNumberGeneratorPermuteBodyIterator, RandomSequenceGeneratorIterator, RandomSequenceWithBoundsAndSeedIterator, RandomSequenceWithBoundsIterator, RangeOperationIterator, RemoveFunctionIterator, RenameExpressionIterator, RepartitionFunctionIterator, ReplaceExpressionIterator, ReturnClauseIterator, ReverseFunctionIterator, RootFileFunctionIterator, SimpleMapExpressionIterator, SlashExprIterator, SortFunctionIterator, StatementsWithExprIterator, StaticUserDefinedFunctionCallIterator, StepExprIterator, StructuredJsonLinesFunctionIterator, SubsequenceFunctionIterator, SwitchRuntimeIterator, TailFunctionIterator, TextFileFunctionIterator, TransformExpressionIterator, TreatIterator, TruncateCollectionIterator, TryCatchRuntimeIterator, TypePromotionIterator, TypeswitchRuntimeIterator, UnaryLookupIterator, UnorderedFunctionIterator, UnparsedTextLinesFunctionIterator, VariableReferenceIterator, XmlFilesFunctionIterator, XmlSchemaCastIterator

public abstract class ItemRuntimePlan
extends RuntimePlan<Item>

Shared immutable compilation state for plans that produce items.

See Also:

• Serialized Form

Field Summary

Fields inherited from class org.rumbledb.runtime.plan.RuntimePlan

staticContext

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ItemRuntimePlan(@NonNull List<? extends ItemRuntimePlan> children, @NonNull RuntimeStaticContext staticContext)

Method Summary

Modifier and Type	Method	Description
protected final ItemRuntimePlan	getChild(int index)
protected final List<ItemRuntimePlan>	getChildren()
final SequenceType	getStaticType()
Map<Name,DynamicContext.VariableDependency>	getVariableDependencies()
boolean	isSparkJobNeeded()
void	print(StringBuilder buffer, int indent)

Methods inherited from class org.rumbledb.runtime.plan.RuntimePlan

getConfiguration, getCursor, getDataFrame, getMetadata, getRDD, getRuntimeStaticContext, materialize, materializeAtMost, materializeAtMostOne, materializeExactlyOne, materializeFirstOrNull

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ItemRuntimePlan

protected ItemRuntimePlan(@NonNull
 @NonNull List<? extends ItemRuntimePlan> children,
 @NonNull
 @NonNull RuntimeStaticContext staticContext)

Method Details

getChild

protected final ItemRuntimePlan getChild(int index)

getChildren

protected final List<ItemRuntimePlan> getChildren()

getStaticType

public final SequenceType getStaticType()

isSparkJobNeeded

public boolean isSparkJobNeeded()

print

public void print(StringBuilder buffer,
 int indent)

getVariableDependencies

public Map<Name,DynamicContext.VariableDependency> getVariableDependencies()