Class SimpleMapExpressionIterator
java.lang.Object
org.rumbledb.runtime.RuntimeIterator
org.rumbledb.runtime.HybridRuntimeIterator
org.rumbledb.runtime.flwor.expression.SimpleMapExpressionIterator
- All Implemented Interfaces:
com.esotericsoftware.kryo.KryoSerializable
,Serializable
,RuntimeIteratorInterface
- See Also:
-
Field Summary
Fields inherited from class org.rumbledb.runtime.HybridRuntimeIterator
result
Fields inherited from class org.rumbledb.runtime.RuntimeIterator
children, currentDynamicContextForLocalExecution, FLOW_EXCEPTION_MESSAGE, hasNext, isOpen, isSequential, isUpdating, staticContext, staticURI
-
Constructor Summary
ConstructorsConstructorDescriptionSimpleMapExpressionIterator
(RuntimeIterator sequence, RuntimeIterator mapExpression, RuntimeStaticContext staticContext) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
getDataFrame
(DynamicContext context) org.apache.spark.api.java.JavaRDD<Item>
getRDDAux
(DynamicContext dynamicContext) protected boolean
protected boolean
protected Item
protected void
protected void
Methods inherited from class org.rumbledb.runtime.HybridRuntimeIterator
close, dataFrameToRDDOfItems, fallbackToRDDIfDFNotImplemented, getRDD, hasNext, implementsLocal, implementsRDD, materialize, materializeAtMostOneItemOrNull, materializeExactlyOneItem, materializeFirstItemOrNull, materializeNFirstItems, next, open, reset
Methods inherited from class org.rumbledb.runtime.RuntimeIterator
bindToVariableInDynamicContext, canProduceDataFrame, deepCopy, generateNativeQuery, getConfiguration, getEffectiveBooleanValue, getEffectiveBooleanValueOrCheckPosition, getHighestExecutionMode, getMetadata, getOrCreateDataFrame, getPendingUpdateList, getStaticType, isDataFrame, isLocal, isOpen, isRDD, isRDDOrDataFrame, isSequential, isSparkJobNeeded, isUpdating, materialize, materializeAtMostOneItemOrDefault, print, printToStandardError, read, setStaticContext, write
-
Constructor Details
-
SimpleMapExpressionIterator
public SimpleMapExpressionIterator(RuntimeIterator sequence, RuntimeIterator mapExpression, RuntimeStaticContext staticContext)
-
-
Method Details
-
getRDDAux
- Specified by:
getRDDAux
in classHybridRuntimeIterator
-
openLocal
protected void openLocal()- Specified by:
openLocal
in classHybridRuntimeIterator
-
closeLocal
protected void closeLocal()- Specified by:
closeLocal
in classHybridRuntimeIterator
-
resetLocal
protected void resetLocal()- Specified by:
resetLocal
in classHybridRuntimeIterator
-
hasNextLocal
protected boolean hasNextLocal()- Specified by:
hasNextLocal
in classHybridRuntimeIterator
-
nextLocal
- Specified by:
nextLocal
in classHybridRuntimeIterator
-
getVariableDependencies
- Overrides:
getVariableDependencies
in classRuntimeIterator
-
implementsDataFrames
protected boolean implementsDataFrames()- Overrides:
implementsDataFrames
in classHybridRuntimeIterator
-
getDataFrame
- Overrides:
getDataFrame
in classRuntimeIterator
-