Class MapForEachFunctionIterator
java.lang.Object
org.rumbledb.runtime.RuntimeIterator
org.rumbledb.runtime.HybridRuntimeIterator
org.rumbledb.runtime.functions.maps.MapForEachFunctionIterator
- All Implemented Interfaces:
com.esotericsoftware.kryo.KryoSerializable,Serializable,RuntimeIteratorInterface
FO 3.1 map:for-each($map as map(*), $action as function(xs:anyAtomicType, item()*) as item()*)
as item()*.
- 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
ConstructorsConstructorDescriptionMapForEachFunctionIterator(List<RuntimeIterator> arguments, RuntimeStaticContext staticContext) -
Method Summary
Modifier and TypeMethodDescriptionprotected voidgetDataFrame(DynamicContext dynamicContext) org.apache.spark.api.java.JavaRDD<Item>getRDDAux(DynamicContext context) 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
-
MapForEachFunctionIterator
public MapForEachFunctionIterator(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
-
implementsDataFrames
protected boolean implementsDataFrames()- Overrides:
implementsDataFramesin classHybridRuntimeIterator
-
getRDDAux
- Specified by:
getRDDAuxin classHybridRuntimeIterator
-
getDataFrame
- Overrides:
getDataFramein classRuntimeIterator
-