edu.iu.dsc.tws.task.impl.cdfw

Class CDFWWorker

java.lang.Object

edu.iu.dsc.tws.task.impl.cdfw.CDFWWorker

All Implemented Interfaces:

IWorker

public class CDFWWorker
extends java.lang.Object
implements IWorker

This is an implementation of IWorker to support easy deployment of task graphs.

Field Summary

Fields

Modifier and Type	Field and Description
protected TWSChannel	channel The channel
protected Communicator	communicator Communicator
protected Config	config Configuration
protected IPersistentVolume	persistentVolume Persistent volume
protected CDFWRuntime	taskExecutor The task executor to be used
protected IVolatileVolume	volatileVolume Volatile volume
protected IWorkerController	workerController Controller
protected int	workerId This id

Constructor Summary

Constructors

Constructor and Description
CDFWWorker()

Method Summary

Modifier and Type	Method and Description
void	execute(Config cfg, JobAPI.Job job, IWorkerController wController, IPersistentVolume pVolume, IVolatileVolume vVolume) Execute with the resources configured

Methods inherited from class java.lang.Object

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

Field Detail

channel

protected TWSChannel channel

The channel

communicator

protected Communicator communicator

Communicator

workerId

protected int workerId

This id

workerController

protected IWorkerController workerController

Controller

persistentVolume

protected IPersistentVolume persistentVolume

Persistent volume

volatileVolume

protected IVolatileVolume volatileVolume

Volatile volume

config

protected Config config

Configuration

taskExecutor

protected CDFWRuntime taskExecutor

The task executor to be used

Constructor Detail

CDFWWorker

public CDFWWorker()

Method Detail

execute

public void execute(Config cfg,
                    JobAPI.Job job,
                    IWorkerController wController,
                    IPersistentVolume pVolume,
                    IVolatileVolume vVolume)

Description copied from interface: IWorker

Execute with the resources configured

Specified by:

execute in interface IWorker

Parameters:

cfg - configuration

job - the worker id

wController - the worker controller

pVolume - information about persistent file system

vVolume - information about volatile file system