edu.iu.dsc.tws.task.impl

Class TaskWorker

java.lang.Object

edu.iu.dsc.tws.task.impl.TaskWorker

All Implemented Interfaces:

IWorker

Direct Known Subclasses:

BasicComputation, BenchWindowTaskWorker, DataflowAddNodeExperiment, DataflowNodeExperiment, DataParallelWorker, MultiComputeTasksGraphExample, MultiStageGraph, PageRankWorker, SingleSourceShortestPathWorker, SourceTaskDataLoader, StormBenchmark, SvmSgdAdvancedRunner, SvmSgdIterativeRunner, SvmSgdOnlineRunner, SvmSgdRunner, TaskWorkerDataLoader, Twister2StormWorker

public abstract class TaskWorker
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 ComputeEnvironment	computeEnvironment
protected Config	config Configuration
protected IPersistentVolume	persistentVolume Persistent volume
protected TaskExecutor	taskExecutor The task executor to be used
protected IVolatileVolume	volatileVolume Volatile volume
protected IWorkerController	workerController Controller
protected WorkerEnvironment	workerEnvironment Worker environment
protected int	workerId This id

Constructor Summary

Constructors

Constructor and Description
TaskWorker()

Method Summary

Modifier and Type	Method and Description
abstract void	execute() A user needs to implement this method to create the task graph and execute it
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

workerEnvironment

protected WorkerEnvironment workerEnvironment

Worker environment

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 TaskExecutor taskExecutor

The task executor to be used

computeEnvironment

protected ComputeEnvironment computeEnvironment

Constructor Detail

TaskWorker

public TaskWorker()

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

execute

public abstract void execute()

A user needs to implement this method to create the task graph and execute it