Class ArrayForEachFunctionIterator
java.lang.Object
org.rumbledb.runtime.RuntimeIterator
org.rumbledb.runtime.HybridRuntimeIterator
org.rumbledb.runtime.functions.arrays.ArrayForEachFunctionIterator
- All Implemented Interfaces:
com.esotericsoftware.kryo.KryoSerializable,Serializable,RuntimeIteratorInterface
XPath and XQuery Functions and Operators 3.1
array:for-each:
array:for-each($array as array(*), $action as function(item()*) as item()*) as array(*).- See Also:
-
Field Summary
Fields inherited from class org.rumbledb.runtime.HybridRuntimeIterator
resultFields inherited from class org.rumbledb.runtime.RuntimeIterator
children, currentDynamicContextForLocalExecution, FLOW_EXCEPTION_MESSAGE, hasNext, isOpen, isSequential, isUpdating, staticContext, staticURI -
Constructor Summary
ConstructorsConstructorDescriptionArrayForEachFunctionIterator(List<RuntimeIterator> arguments, RuntimeStaticContext staticContext) -
Method Summary
Modifier and TypeMethodDescriptionprotected voidgetDataFrame(DynamicContext dynamicContext) org.apache.spark.api.java.JavaRDD<Item>getRDDAux(DynamicContext dynamicContext) protected booleanprotected booleanprotected Itemprotected voidprotected voidMethods inherited from class org.rumbledb.runtime.HybridRuntimeIterator
close, collectRDDwithLimit, dataFrameToRDDOfItems, fallbackToRDDIfDFNotImplemented, getRDD, hasNext, implementsLocal, implementsRDD, materialize, materializeAtMostOneItemOrNull, materializeExactlyOneItem, materializeFirstItemOrNull, materializeNFirstItems, next, open, resetMethods inherited from class org.rumbledb.runtime.RuntimeIterator
bindToVariableInDynamicContext, canProduceDataFrame, deepCopy, generateNativeQuery, getConfiguration, getEffectiveBooleanValue, getEffectiveBooleanValueOrCheckPosition, getHighestExecutionMode, getMetadata, getOrCreateDataFrame, getPendingUpdateList, getRuntimeStaticContext, getStaticType, getVariableDependencies, isDataFrame, isLocal, isOpen, isRDD, isRDDOrDataFrame, isSequential, isSparkJobNeeded, isUpdating, materialize, materializeAtMostOneItemOrDefault, print, printToStandardError, read, setStaticContext, write
-
Constructor Details
-
ArrayForEachFunctionIterator
public ArrayForEachFunctionIterator(List<RuntimeIterator> arguments, RuntimeStaticContext staticContext)
-
-
Method Details
-
openLocal
protected void openLocal()- Specified by:
openLocalin classHybridRuntimeIterator
-
hasNextLocal
protected boolean hasNextLocal()- Specified by:
hasNextLocalin classHybridRuntimeIterator
-
nextLocal
- Specified by:
nextLocalin classHybridRuntimeIterator
-
resetLocal
protected void resetLocal()- Specified by:
resetLocalin classHybridRuntimeIterator
-
closeLocal
protected void closeLocal()- Specified by:
closeLocalin classHybridRuntimeIterator
-
getRDDAux
- Specified by:
getRDDAuxin classHybridRuntimeIterator
-
implementsDataFrames
protected boolean implementsDataFrames()- Overrides:
implementsDataFramesin classHybridRuntimeIterator
-
getDataFrame
- Overrides:
getDataFramein classRuntimeIterator
-