edu.iu.dsc.tws.executor.core.batch

Class TaskBatchInstance

java.lang.Object

edu.iu.dsc.tws.executor.core.batch.TaskBatchInstance

All Implemented Interfaces:

INodeInstance, ISync

public class TaskBatchInstance
extends java.lang.Object
implements INodeInstance, ISync

The class represents the instance of the executing task

Constructor Summary

Constructors

Constructor and Description

TaskBatchInstance(ICompute task, java.util.concurrent.BlockingQueue<IMessage> inQueue, java.util.concurrent.BlockingQueue<IMessage> outQueue, Config config, java.lang.String tName, int taskId, int globalTaskId, int tIndex, int parallel, int wId, java.util.Map<java.lang.String,java.lang.Object> cfgs, java.util.Map<java.lang.String,java.util.Set<java.lang.String>> inEdges, java.util.Map<java.lang.String,java.lang.String> outEdges, TaskSchedulePlan taskSchedule, CheckpointingClient checkpointingClient, java.lang.String taskGraphName, long tasksVersion)

Method Summary

Modifier and Type	Method and Description
void	close() Calls at the end to clean up
boolean	execute() Execute
int	getId() Get task id
int	getIndex()
java.util.concurrent.BlockingQueue<IMessage>	getInQueue()
INode	getNode() Get the node of this instance
boolean	isComplete() Progress the communication
void	prepare(Config cfg) Prepare for an execution
void	registerInParallelOperation(java.lang.String edge, IParallelOperation op)
void	registerOutParallelOperation(java.lang.String edge, IParallelOperation op)
void	reset() Lets reset the node instance for a new execution
boolean	sync(java.lang.String edge, byte[] value) Callback for sync

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskBatchInstance

public TaskBatchInstance(ICompute task,
                         java.util.concurrent.BlockingQueue<IMessage> inQueue,
                         java.util.concurrent.BlockingQueue<IMessage> outQueue,
                         Config config,
                         java.lang.String tName,
                         int taskId,
                         int globalTaskId,
                         int tIndex,
                         int parallel,
                         int wId,
                         java.util.Map<java.lang.String,java.lang.Object> cfgs,
                         java.util.Map<java.lang.String,java.util.Set<java.lang.String>> inEdges,
                         java.util.Map<java.lang.String,java.lang.String> outEdges,
                         TaskSchedulePlan taskSchedule,
                         CheckpointingClient checkpointingClient,
                         java.lang.String taskGraphName,
                         long tasksVersion)

Method Detail

prepare

public void prepare(Config cfg)

Description copied from interface: INodeInstance

Prepare for an execution

Specified by:

prepare in interface INodeInstance

Parameters:

cfg - configuration

registerOutParallelOperation

public void registerOutParallelOperation(java.lang.String edge,
                                         IParallelOperation op)

registerInParallelOperation

public void registerInParallelOperation(java.lang.String edge,
                                        IParallelOperation op)

execute

public boolean execute()

Description copied from interface: INodeInstance

Execute

Specified by:

execute in interface INodeInstance

Returns:

true if further execution is needed

sync

public boolean sync(java.lang.String edge,
                    byte[] value)

Description copied from interface: ISync

Callback for sync

Specified by:

sync in interface ISync

Parameters:

edge - edge name

value - value, can be null

Returns:

if we handled the sync, return true

isComplete

public boolean isComplete()

Description copied from interface: INodeInstance

Progress the communication

Specified by:

isComplete in interface INodeInstance

Returns:

true if further communication progress is required

getId

public int getId()

Description copied from interface: INodeInstance

Get task id

Specified by:

getId in interface INodeInstance

Returns:

task id

getIndex

public int getIndex()

Specified by:

getIndex in interface INodeInstance

getNode

public INode getNode()

Description copied from interface: INodeInstance

Get the node of this instance

Specified by:

getNode in interface INodeInstance

Returns:

the graph node

close

public void close()

Description copied from interface: INodeInstance

Calls at the end to clean up

Specified by:

close in interface INodeInstance

reset

public void reset()

Description copied from interface: INodeInstance

Lets reset the node instance for a new execution

Specified by:

reset in interface INodeInstance

getInQueue

public java.util.concurrent.BlockingQueue<IMessage> getInQueue()