Package org.rumbledb.runtime.control
Class TryCatchRuntimeIterator
java.lang.Object
org.rumbledb.runtime.RuntimeIterator
org.rumbledb.runtime.LocalRuntimeIterator
org.rumbledb.runtime.control.TryCatchRuntimeIterator
- 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
ConstructorsConstructorDescriptionTryCatchRuntimeIterator
(RuntimeIterator tryExpression, Map<String, RuntimeIterator> catchExpressions, RuntimeIterator catchAllExpression, RuntimeStaticContext staticContext) -
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
next()
void
open
(DynamicContext context) void
reset
(DynamicContext context) Methods inherited from class org.rumbledb.runtime.RuntimeIterator
bindToVariableInDynamicContext, canProduceDataFrame, deepCopy, generateNativeQuery, getConfiguration, getDataFrame, getEffectiveBooleanValue, getEffectiveBooleanValueOrCheckPosition, getHighestExecutionMode, getMetadata, getOrCreateDataFrame, getPendingUpdateList, getRDD, getStaticType, getVariableDependencies, hasNext, isDataFrame, isLocal, isOpen, isRDD, isRDDOrDataFrame, isSequential, isSparkJobNeeded, isUpdating, materialize, materialize, materializeAtMostOneItemOrDefault, materializeAtMostOneItemOrNull, materializeExactlyOneItem, materializeFirstItemOrNull, materializeNFirstItems, print, printToStandardError, read, setStaticContext, write
-
Constructor Details
-
TryCatchRuntimeIterator
public TryCatchRuntimeIterator(RuntimeIterator tryExpression, Map<String, RuntimeIterator> catchExpressions, RuntimeIterator catchAllExpression, RuntimeStaticContext staticContext)
-
-
Method Details
-
open
- Specified by:
open
in interfaceRuntimeIteratorInterface
- Overrides:
open
in classRuntimeIterator
-
next
- Specified by:
next
in interfaceRuntimeIteratorInterface
- Specified by:
next
in classRuntimeIterator
-
reset
- Specified by:
reset
in interfaceRuntimeIteratorInterface
- Overrides:
reset
in classRuntimeIterator
-
close
public void close()- Specified by:
close
in interfaceRuntimeIteratorInterface
- Overrides:
close
in classRuntimeIterator
-