org.globus.cog.karajan.workflow.nodes
Class AbstractParallelIterator

java.lang.Object
  org.globus.cog.karajan.workflow.nodes.FlowNode
      org.globus.cog.karajan.workflow.nodes.FlowContainer
          org.globus.cog.karajan.workflow.nodes.Sequential
              org.globus.cog.karajan.workflow.nodes.AbstractSequentialWithArguments
                  org.globus.cog.karajan.workflow.nodes.PartialArgumentsContainer
                      org.globus.cog.karajan.workflow.nodes.AbstractIterator
                          org.globus.cog.karajan.workflow.nodes.AbstractParallelIterator

All Implemented Interfaces:

EventListener, ExtendedFlowElement, FlowElement, LoadListener

Direct Known Subclasses:

ParallelFor

public abstract class AbstractParallelIterator

extends AbstractIterator

Nested Class Summary

Nested classes inherited from class org.globus.cog.karajan.workflow.nodes.FlowNode

FlowNode.FNTP

Field Summary

Fields inherited from class org.globus.cog.karajan.workflow.nodes.AbstractIterator

CHILD_FAILED, INDEX, ITERATE, ITERATOR, RUNNING, VAR

Fields inherited from class org.globus.cog.karajan.workflow.nodes.AbstractSequentialWithArguments

commonArguments, QUOTED

Fields inherited from class org.globus.cog.karajan.workflow.nodes.FlowContainer

CALLER

Fields inherited from class org.globus.cog.karajan.workflow.nodes.FlowNode

debug, startCount, TEXT, threadTracker

Constructor Summary

AbstractParallelIterator()

Method Summary

protected void	childCompleted(VariableStack stack)
void	iterate(VariableStack stack, Identifier var, KarajanIterator i)
protected void	iterationCompleted(VariableStack stack)
void	notificationEvent(NotificationEvent e)

Methods inherited from class org.globus.cog.karajan.workflow.nodes.AbstractIterator

getIterator, iterate, partialArgumentsEvaluated

Methods inherited from class org.globus.cog.karajan.workflow.nodes.PartialArgumentsContainer

executeChildren, executeSingle, getArgCount, initializeStatic, startRest

Methods inherited from class org.globus.cog.karajan.workflow.nodes.AbstractSequentialWithArguments

argumentsEvaluated, checkArguments, getArgument, getArgument, getArgumentCount, getArgumentIndex, getArgumentNames, getArguments, getMaxArgIndex, getNonpropargs, getPropargs, getQuotedArgs, getSortedArgs, getVargs, getVargsAsArray, hasArgument, hasNestedArguments, hasVariableArguments, initializeArgs, newNameBindingVariableArguments, newVariableArguments, pre, processArguments, setArguments, setArguments, setHasVargs, setNestedArgs, setNonpropargs, setQuotedArgs, setVargs

Methods inherited from class org.globus.cog.karajan.workflow.nodes.Sequential

exit, moreToExecute, startNext

Methods inherited from class org.globus.cog.karajan.workflow.nodes.FlowContainer

addChannel, execute, isOptimizable, post, setOptimize

Methods inherited from class org.globus.cog.karajan.workflow.nodes.FlowNode

abort, acceptsInlineText, addElement, checkClass, checkCompleted, checkFailed, complete, controlEvent, copy, echo, echo, elementCount, elements, end, event, executeErrorHandler, executeSimple, expandProperty, expandProperty, expandPropertyAsString, fail, fail, failIfNotDefined, failIfNull, failIfNull, failImmediately, failImmediately, failImmediately, fireControlEvent, fireMonitoringEvent, fireNotificationEvent, fireStatusMonitoringEvent, get_locator, getBooleanProperty, getBooleanProperty, getCanonicalType, getElement, getElementType, getIntProperty, getIntProperty, getParent, getProjectNode, getProperty, getStringProperty, getTreeProperty, getVar, hasFrame, hashCode, hasProperty, isCheckpointable, isSimple, isSystemProperty, loadComplete, loadStarted, monitoringEvent, propertyNames, removeProperty, restart, restartElement, ret, ret, set_locator, setAcceptsInlineText, setCheckpointable, setElementType, setFrame, setParent, setProperty, setProperty, setProperty, start, startElement, startElement, toString, verify

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

AbstractParallelIterator

public AbstractParallelIterator()

Method Detail

iterate

public void iterate(VariableStack stack,
                    Identifier var,
                    KarajanIterator i)
             throws ExecutionException

Specified by:

iterate in class AbstractIterator

Throws:

ExecutionException

iterationCompleted

protected final void iterationCompleted(VariableStack stack)
                                 throws ExecutionException

Throws:

ExecutionException

childCompleted

protected final void childCompleted(VariableStack stack)
                             throws ExecutionException

Overrides:

childCompleted in class PartialArgumentsContainer

Throws:

ExecutionException

notificationEvent

public final void notificationEvent(NotificationEvent e)
                             throws ExecutionException

Overrides:

notificationEvent in class AbstractIterator

Throws:

ExecutionException