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

Class SourceBatchInstance

java.lang.Object

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

All Implemented Interfaces:

INodeInstance, ISync

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

Constructor Summary

Constructors

Constructor and Description

SourceBatchInstance(ISource task, 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.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() Execution Method calls the SourceTasks run method to get context
int	getId() Get task id
int	getIndex()
INode	getNode() Get the node of this instance
int	getWorkerId()
boolean	isComplete() Progress the communication
void	prepare(Config cfg) Prepare for an execution
boolean	progressCommunication() Progress the communication and return weather we need to further progress
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

SourceBatchInstance

public SourceBatchInstance(ISource task,
                           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.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

execute

public boolean execute()

Execution Method calls the SourceTasks run method to get context

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

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

reset

public void reset()

Description copied from interface: INodeInstance

Lets reset the node instance for a new execution

Specified by:

reset in interface INodeInstance

close

public void close()

Description copied from interface: INodeInstance

Calls at the end to clean up

Specified by:

close in interface INodeInstance

progressCommunication

public boolean progressCommunication()

Progress the communication and return weather we need to further progress

Returns:

true if further progress is needed

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

registerOutParallelOperation

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

getWorkerId

public int getWorkerId()