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 TypeMethodDescriptionvoidclose()next()voidopen(DynamicContext context) voidreset(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:
openin interfaceRuntimeIteratorInterface- Overrides:
openin classRuntimeIterator
-
next
- Specified by:
nextin interfaceRuntimeIteratorInterface- Specified by:
nextin classRuntimeIterator
-
reset
- Specified by:
resetin interfaceRuntimeIteratorInterface- Overrides:
resetin classRuntimeIterator
-
close
public void close()- Specified by:
closein interfaceRuntimeIteratorInterface- Overrides:
closein classRuntimeIterator
-