Package org.rumbledb.runtime.control
Class IfRuntimeIterator
java.lang.Object
org.rumbledb.runtime.RuntimeIterator
org.rumbledb.runtime.HybridRuntimeIterator
org.rumbledb.runtime.control.IfRuntimeIterator
- 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
ConstructorsConstructorDescriptionIfRuntimeIterator
(RuntimeIterator condition, RuntimeIterator branch, RuntimeIterator elseBranch, boolean isUpdating, RuntimeStaticContext staticContext) IfRuntimeIterator
(RuntimeIterator condition, RuntimeIterator branch, RuntimeIterator elseBranch, RuntimeStaticContext staticContext) -
Method Summary
Modifier and TypeMethodDescriptionvoid
getDataFrame
(DynamicContext dynamicContext) getPendingUpdateList
(DynamicContext context) org.apache.spark.api.java.JavaRDD<Item>
getRDDAux
(DynamicContext dynamicContext) boolean
protected boolean
void
void
selectApplicableIterator
(DynamicContext dynamicContext) 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
-
IfRuntimeIterator
public IfRuntimeIterator(RuntimeIterator condition, RuntimeIterator branch, RuntimeIterator elseBranch, boolean isUpdating, RuntimeStaticContext staticContext) -
IfRuntimeIterator
public IfRuntimeIterator(RuntimeIterator condition, RuntimeIterator branch, RuntimeIterator elseBranch, RuntimeStaticContext staticContext)
-
-
Method Details
-
resetLocal
public void resetLocal()- Specified by:
resetLocal
in classHybridRuntimeIterator
-
openLocal
public void openLocal()- Specified by:
openLocal
in classHybridRuntimeIterator
-
closeLocal
public void closeLocal()- Specified by:
closeLocal
in classHybridRuntimeIterator
-
nextLocal
- Specified by:
nextLocal
in classHybridRuntimeIterator
-
hasNextLocal
public boolean hasNextLocal()- Specified by:
hasNextLocal
in classHybridRuntimeIterator
-
selectApplicableIterator
-
getRDDAux
- Specified by:
getRDDAux
in classHybridRuntimeIterator
-
implementsDataFrames
protected boolean implementsDataFrames()- Overrides:
implementsDataFrames
in classHybridRuntimeIterator
-
getDataFrame
- Overrides:
getDataFrame
in classRuntimeIterator
-
getPendingUpdateList
- Overrides:
getPendingUpdateList
in classRuntimeIterator
-