org.knime.core.node.workflow.virtual
Class ParallelizedChunkContent

java.lang.Object
  org.knime.core.node.workflow.virtual.ParallelizedChunkContent

public final class ParallelizedChunkContent
extends Object

An object representing the copied content of a chunk that is executed in parallel.

Author:

wiswedel, University of Konstanz

Constructor Summary

ParallelizedChunkContent(WorkflowManager manager, NodeID virtualInputID, NodeID virtualOutputID, NodeID[] copiedLoopContent)

Method Summary

void	cancelExecution() Cancel execution.
void	executeChunk() Trigger execution of branch for this chunk.
boolean	executionInProgress()
NodeID[]	getCopiedLoopContent()
PortObject[]	getOutportContent()
NodeID	getVirtualOutputID()
boolean	isExecuted()
void	registerLoopEndStateChangeListener(ParallelizedChunkContentMaster pccm)
void	removeAllNodesFromWorkflow() Remove all nodes (and connections) of this chunk.
void	removeLoopEndStateChangeListener(ParallelizedChunkContentMaster pccm)

Methods inherited from class java.lang.Object

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

Constructor Detail

ParallelizedChunkContent

public ParallelizedChunkContent(WorkflowManager manager,
                                NodeID virtualInputID,
                                NodeID virtualOutputID,
                                NodeID[] copiedLoopContent)

Parameters:

manager -

virtualInputID -

virtualOutputID -

copiedLoopContent -

Throws:

IllegalArgumentException - If the input/output nodes are not of the expected type.

Method Detail

executeChunk

public void executeChunk()

Trigger execution of branch for this chunk.

getVirtualOutputID

public NodeID getVirtualOutputID()

Returns:

the virtualOutputID

getCopiedLoopContent

public NodeID[] getCopiedLoopContent()

Returns:

the copiedLoopContent

registerLoopEndStateChangeListener

public void registerLoopEndStateChangeListener(ParallelizedChunkContentMaster pccm)

Parameters:

nmodel -

removeLoopEndStateChangeListener

public void removeLoopEndStateChangeListener(ParallelizedChunkContentMaster pccm)

Parameters:

nmodel -

removeAllNodesFromWorkflow

public void removeAllNodesFromWorkflow()

Remove all nodes (and connections) of this chunk.

isExecuted

public boolean isExecuted()

Returns:

true if chunk is completely executed.

executionInProgress

public boolean executionInProgress()

Returns:

true if chunk is still being executed (or waiting to be...)

cancelExecution

public void cancelExecution()

Cancel execution.

getOutportContent

public PortObject[] getOutportContent()

Returns:

array with PortObjects at the end node of this chunk.