edu.iu.dsc.tws.api.compute.executor

Interface INodeInstance

All Known Implementing Classes:

SourceBatchInstance, SourceStreamingInstance, TaskBatchInstance, TaskStreamingInstance

public interface INodeInstance

Method Summary

Modifier and Type	Method and Description
void	close() Calls at the end to clean up
boolean	execute() Execute
default int	getId() Get task id
int	getIndex()
INode	getNode() Get the node of this instance
default boolean	isComplete() Progress the communication
void	prepare(Config cfg) Prepare for an execution
default void	reset() Lets reset the node instance for a new execution

Method Detail

getId

default int getId()

Get task id

Returns:

task id

getIndex

int getIndex()

execute

boolean execute()

Execute

Returns:

true if further execution is needed

prepare

void prepare(Config cfg)

Prepare for an execution

Parameters:

cfg - configuration

reset

default void reset()

Lets reset the node instance for a new execution

isComplete

default boolean isComplete()

Progress the communication

Returns:

true if further communication progress is required

getNode

INode getNode()

Get the node of this instance

Returns:

the graph node

close

void close()

Calls at the end to clean up