Class ArrayMembersFunctionIterator
java.lang.Object
org.rumbledb.runtime.RuntimeIterator
org.rumbledb.runtime.HybridRuntimeIterator
org.rumbledb.runtime.functions.arrays.ArrayMembersFunctionIterator
- 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
ConstructorsConstructorDescriptionArrayMembersFunctionIterator
(List<RuntimeIterator> arguments, RuntimeStaticContext staticContext) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
org.apache.spark.api.java.JavaRDD<Item>
getRDDAux
(DynamicContext context) protected boolean
protected Item
protected void
protected void
void
Methods inherited from class org.rumbledb.runtime.HybridRuntimeIterator
close, dataFrameToRDDOfItems, fallbackToRDDIfDFNotImplemented, getRDD, hasNext, implementsDataFrames, implementsLocal, implementsRDD, materialize, materializeAtMostOneItemOrNull, materializeExactlyOneItem, materializeFirstItemOrNull, materializeNFirstItems, next, open, reset
Methods inherited from class org.rumbledb.runtime.RuntimeIterator
bindToVariableInDynamicContext, canProduceDataFrame, deepCopy, generateNativeQuery, getConfiguration, getDataFrame, getEffectiveBooleanValue, getEffectiveBooleanValueOrCheckPosition, getHighestExecutionMode, getMetadata, getOrCreateDataFrame, getPendingUpdateList, getStaticType, getVariableDependencies, isDataFrame, isLocal, isOpen, isRDD, isRDDOrDataFrame, isSequential, isSparkJobNeeded, isUpdating, materialize, materializeAtMostOneItemOrDefault, print, printToStandardError, read, setStaticContext, write
-
Constructor Details
-
ArrayMembersFunctionIterator
public ArrayMembersFunctionIterator(List<RuntimeIterator> arguments, RuntimeStaticContext staticContext)
-
-
Method Details
-
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
-
setNextResult
public void setNextResult() -
getRDDAux
- Specified by:
getRDDAux
in classHybridRuntimeIterator
-