Package org.rumbledb.runtime.functions
Class FunctionItemCallIterator
java.lang.Object
org.rumbledb.runtime.RuntimeIterator
org.rumbledb.runtime.HybridRuntimeIterator
org.rumbledb.runtime.functions.FunctionItemCallIterator
- 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
ConstructorsConstructorDescriptionFunctionItemCallIterator
(Item functionItem, List<RuntimeIterator> functionArguments, RuntimeStaticContext staticContext) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
getDataFrame
(DynamicContext dynamicContext) getPendingUpdateList
(DynamicContext context) org.apache.spark.api.java.JavaRDD<Item>
getRDDAux
(DynamicContext dynamicContext) protected boolean
protected boolean
void
protected void
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, getStaticType, getVariableDependencies, isDataFrame, isLocal, isOpen, isRDD, isRDDOrDataFrame, isSequential, isSparkJobNeeded, isUpdating, materialize, materializeAtMostOneItemOrDefault, print, printToStandardError, read, setStaticContext, write
-
Constructor Details
-
FunctionItemCallIterator
public FunctionItemCallIterator(Item functionItem, List<RuntimeIterator> functionArguments, RuntimeStaticContext staticContext)
-
-
Method Details
-
openLocal
public void openLocal()- Specified by:
openLocal
in classHybridRuntimeIterator
-
nextLocal
- Specified by:
nextLocal
in classHybridRuntimeIterator
-
hasNextLocal
protected boolean hasNextLocal()- Specified by:
hasNextLocal
in classHybridRuntimeIterator
-
resetLocal
protected void resetLocal()- Specified by:
resetLocal
in classHybridRuntimeIterator
-
closeLocal
protected void closeLocal()- Specified by:
closeLocal
in classHybridRuntimeIterator
-
setNextResult
public void setNextResult() -
getRDDAux
- Specified by:
getRDDAux
in classHybridRuntimeIterator
-
implementsDataFrames
protected boolean implementsDataFrames()- Overrides:
implementsDataFrames
in classHybridRuntimeIterator
-
getDataFrame
- Overrides:
getDataFrame
in classRuntimeIterator
-
getPendingUpdateList
- Overrides:
getPendingUpdateList
in classRuntimeIterator
-