Class StatementsOnlyIterator
java.lang.Object
org.rumbledb.runtime.RuntimeIterator
org.rumbledb.runtime.AtMostOneItemLocalRuntimeIterator
org.rumbledb.runtime.scripting.block.StatementsOnlyIterator
- All Implemented Interfaces:
com.esotericsoftware.kryo.KryoSerializable,Serializable,RuntimeIteratorInterface
- See Also:
-
Field Summary
Fields inherited from class org.rumbledb.runtime.RuntimeIterator
children, currentDynamicContextForLocalExecution, FLOW_EXCEPTION_MESSAGE, hasNext, isOpen, isSequential, isUpdating, staticContext, staticURI -
Constructor Summary
ConstructorsConstructorDescriptionStatementsOnlyIterator(List<RuntimeIterator> children, RuntimeStaticContext staticContext) -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()voidmaterializeFirstItemOrNull(DynamicContext dynamicContext) next()voidopen(DynamicContext dynamicContext) voidreset(DynamicContext dynamicContext) Methods inherited from class org.rumbledb.runtime.AtMostOneItemLocalRuntimeIterator
getEffectiveBooleanValueOrCheckPosition, getRDD, materialize, materializeAtMostOneItemOrNull, materializeExactlyOneItem, materializeNFirstItemsMethods inherited from class org.rumbledb.runtime.RuntimeIterator
bindToVariableInDynamicContext, canProduceDataFrame, deepCopy, generateNativeQuery, getConfiguration, getDataFrame, getEffectiveBooleanValue, getHighestExecutionMode, getMetadata, getOrCreateDataFrame, getPendingUpdateList, getStaticType, getVariableDependencies, hasNext, isDataFrame, isLocal, isOpen, isRDD, isRDDOrDataFrame, isSequential, isSparkJobNeeded, isUpdating, materialize, materializeAtMostOneItemOrDefault, print, printToStandardError, read, setStaticContext, write
-
Constructor Details
-
StatementsOnlyIterator
-
-
Method Details
-
materializeFirstItemOrNull
- Specified by:
materializeFirstItemOrNullin classAtMostOneItemLocalRuntimeIterator
-
iterateChildren
public void iterateChildren() -
open
- Specified by:
openin interfaceRuntimeIteratorInterface- Overrides:
openin classAtMostOneItemLocalRuntimeIterator
-
close
public void close()- Specified by:
closein interfaceRuntimeIteratorInterface- Overrides:
closein classAtMostOneItemLocalRuntimeIterator
-
reset
- Specified by:
resetin interfaceRuntimeIteratorInterface- Overrides:
resetin classAtMostOneItemLocalRuntimeIterator
-
next
- Specified by:
nextin interfaceRuntimeIteratorInterface- Overrides:
nextin classAtMostOneItemLocalRuntimeIterator
-