|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.knime.core.node.workflow.NodeExecutionJob
public abstract class NodeExecutionJob
Runnable that represents the execution of a node. This abstract class defines the overall procedure of an execution including setup (e.g. to copy the necessary data onto a cluster master), main execution and result retrieval. It also reflects the current step of the execution in the node's state.
Constructor Summary | |
---|---|
protected |
NodeExecutionJob(NodeContainer nc,
PortObject[] data)
Creates a new execution job for a given node. |
Method Summary | |
---|---|
protected void |
afterExecute()
Called to finalize the execution. |
protected void |
beforeExecute()
Called right after the node has switched to the NodeContainer.State.PREEXECUTE
state. |
protected abstract boolean |
cancel()
Called when the execution is to be canceled. |
protected NodeContainer |
getNodeContainer()
Access method for the accompanying node container. |
protected PortObject[] |
getPortObjects()
Access method for the input port objects. |
protected abstract boolean |
isReConnecting()
Whether this job has been disconnected (from a cluster execution, e.g.) and is now resuming the execution. |
(package private) boolean |
isSavedForDisconnect()
|
protected abstract NodeContainerExecutionStatus |
mainExecute()
Called when the main execution takes place. |
void |
run()
|
(package private) void |
setSavedForDisconnect(boolean isSavedForDisconnect)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
protected NodeExecutionJob(NodeContainer nc, PortObject[] data)
nc
- The node that is to be executed.data
- The input data of that node, must not be null,
nor contain null elements.Method Detail |
---|
public final void run()
run
in interface Runnable
protected abstract boolean isReConnecting()
protected void beforeExecute()
NodeContainer.State.PREEXECUTE
state. Remote job executors will setup the execution environment in this
step and therefore overwrite this (empty) method.
protected abstract NodeContainerExecutionStatus mainExecute()
NodeContainer.State.EXECUTING
or
NodeContainer.State.EXECUTINGREMOTELY
when this method is called.
protected void afterExecute()
protected abstract boolean cancel()
Future.cancel(boolean)
protected final PortObject[] getPortObjects()
protected final NodeContainer getNodeContainer()
void setSavedForDisconnect(boolean isSavedForDisconnect)
isSavedForDisconnect
- the isSavedForDisconnect to setboolean isSavedForDisconnect()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |