Package org.rumbledb.runtime.primary
Class ArrayRuntimeIterator
java.lang.Object
org.rumbledb.runtime.RuntimeIterator
org.rumbledb.runtime.AtMostOneItemLocalRuntimeIterator
org.rumbledb.runtime.primary.ArrayRuntimeIterator
- All Implemented Interfaces:
com.esotericsoftware.kryo.KryoSerializable,Serializable,RuntimeIteratorInterface
- See Also:
-
Field Summary
Fields inherited from class org.rumbledb.runtime.RuntimeIterator
children, currentDynamicContextForLocalExecution, FLOW_EXCEPTION_MESSAGE, hasNext, isOpen, isSequential, isUpdating, staticContext, staticURI -
Constructor Summary
ConstructorsConstructorDescriptionArrayRuntimeIterator(List<RuntimeIterator> memberIterators, boolean isFixedSlotsArrayConstructor, RuntimeStaticContext staticContext) Square array constructor: each child iterator produces one member (possibly a sequence).ArrayRuntimeIterator(RuntimeIterator arrayItems, RuntimeStaticContext staticContext) Curly array constructor: single child whose items become singleton members. -
Method Summary
Modifier and TypeMethodDescriptiongenerateNativeQuery(NativeClauseContext nativeClauseContext) This function generate (if possible) a native spark-sql query that maps the inner working of the iteratormaterializeFirstItemOrNull(DynamicContext dynamicContext) Methods inherited from class org.rumbledb.runtime.AtMostOneItemLocalRuntimeIterator
close, getEffectiveBooleanValueOrCheckPosition, getRDD, materialize, materializeAtMostOneItemOrNull, materializeExactlyOneItem, materializeNFirstItems, next, open, resetMethods inherited from class org.rumbledb.runtime.RuntimeIterator
bindToVariableInDynamicContext, canProduceDataFrame, deepCopy, getConfiguration, getDataFrame, getEffectiveBooleanValue, getHighestExecutionMode, getMetadata, getOrCreateDataFrame, getPendingUpdateList, getRuntimeStaticContext, getStaticType, getVariableDependencies, hasNext, isDataFrame, isLocal, isOpen, isRDD, isRDDOrDataFrame, isSequential, isSparkJobNeeded, isUpdating, materialize, materializeAtMostOneItemOrDefault, print, printToStandardError, read, setStaticContext, write
-
Constructor Details
-
ArrayRuntimeIterator
Curly array constructor: single child whose items become singleton members. -
ArrayRuntimeIterator
public ArrayRuntimeIterator(List<RuntimeIterator> memberIterators, boolean isFixedSlotsArrayConstructor, RuntimeStaticContext staticContext) Square array constructor: each child iterator produces one member (possibly a sequence).
-
-
Method Details
-
materializeFirstItemOrNull
- Specified by:
materializeFirstItemOrNullin classAtMostOneItemLocalRuntimeIterator
-
generateNativeQuery
Description copied from class:RuntimeIteratorThis function generate (if possible) a native spark-sql query that maps the inner working of the iterator- Overrides:
generateNativeQueryin classRuntimeIterator- Parameters:
nativeClauseContext- context information to generate the native query- Returns:
- a native clause context with the spark-sql native query to get an equivalent result of the iterator, or [NativeClauseContext.NoNativeQuery] if it is not possible
-