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 TypeMethodDescriptionvoid
close()
void
materializeFirstItemOrNull
(DynamicContext dynamicContext) next()
void
open
(DynamicContext dynamicContext) void
reset
(DynamicContext dynamicContext) Methods inherited from class org.rumbledb.runtime.AtMostOneItemLocalRuntimeIterator
getEffectiveBooleanValueOrCheckPosition, getRDD, materialize, materializeAtMostOneItemOrNull, materializeExactlyOneItem, materializeNFirstItems
Methods 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:
materializeFirstItemOrNull
in classAtMostOneItemLocalRuntimeIterator
-
iterateChildren
public void iterateChildren() -
open
- Specified by:
open
in interfaceRuntimeIteratorInterface
- Overrides:
open
in classAtMostOneItemLocalRuntimeIterator
-
close
public void close()- Specified by:
close
in interfaceRuntimeIteratorInterface
- Overrides:
close
in classAtMostOneItemLocalRuntimeIterator
-
reset
- Specified by:
reset
in interfaceRuntimeIteratorInterface
- Overrides:
reset
in classAtMostOneItemLocalRuntimeIterator
-
next
- Specified by:
next
in interfaceRuntimeIteratorInterface
- Overrides:
next
in classAtMostOneItemLocalRuntimeIterator
-