edu.iu.dsc.tws.examples.ml.svm.comms

Class CommsWorker

java.lang.Object

edu.iu.dsc.tws.examples.ml.svm.comms.CommsWorker

All Implemented Interfaces:

IWorker

Direct Known Subclasses:

InputDataStreamer, SVMCommsReducer

public abstract class CommsWorker
extends java.lang.Object
implements IWorker

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	CommsWorker.DataStreamer

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String	commsType
protected int	features
protected java.util.Map<java.lang.Integer,java.lang.Boolean>	finishedSources
protected double[][]	inputDataArray
protected LogicalPlan	logicalPlan
protected int	parallelism
protected boolean	sourcesDone
protected SVMJobParameters	svmJobParameters
protected java.util.List<java.lang.Integer>	taskStages
protected int	testingSamples
protected int	trainingSamples
protected int	workerId

Constructor Summary

Constructors

Constructor and Description
CommsWorker()

Method Summary

Modifier and Type	Method and Description
void	close()
void	execute(Config cfg, JobAPI.Job job, IWorkerController workerController, IPersistentVolume persistentVolume, IVolatileVolume volatileVolume) Execute with the resources configured
protected abstract void	execute(WorkerEnvironment wEnv)
protected void	finishCommunication(int src)
abstract java.util.List<java.lang.Integer>	generateTaskStages()
protected abstract boolean	isDone()
protected void	progress()
protected abstract void	progressCommunication()
protected abstract boolean	sendMessages(int task, java.lang.Object data, int flag)

Methods inherited from class java.lang.Object

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

Field Detail

finishedSources

protected final java.util.Map<java.lang.Integer,java.lang.Boolean> finishedSources

workerId

protected int workerId

logicalPlan

protected LogicalPlan logicalPlan

svmJobParameters

protected SVMJobParameters svmJobParameters

sourcesDone

protected boolean sourcesDone

inputDataArray

protected double[][] inputDataArray

features

protected int features

trainingSamples

protected int trainingSamples

testingSamples

protected int testingSamples

parallelism

protected int parallelism

taskStages

protected java.util.List<java.lang.Integer> taskStages

commsType

protected java.lang.String commsType

Constructor Detail

CommsWorker

public CommsWorker()

Method Detail

execute

public void execute(Config cfg,
                    JobAPI.Job job,
                    IWorkerController workerController,
                    IPersistentVolume persistentVolume,
                    IVolatileVolume volatileVolume)

Description copied from interface: IWorker

Execute with the resources configured

Specified by:

execute in interface IWorker

Parameters:

cfg - configuration

job - the worker id

workerController - the worker controller

persistentVolume - information about persistent file system

volatileVolume - information about volatile file system

execute

protected abstract void execute(WorkerEnvironment wEnv)

progressCommunication

protected abstract void progressCommunication()

isDone

protected abstract boolean isDone()

sendMessages

protected abstract boolean sendMessages(int task,
                                        java.lang.Object data,
                                        int flag)

progress

protected void progress()

close

public void close()

finishCommunication

protected void finishCommunication(int src)

generateTaskStages

public abstract java.util.List<java.lang.Integer> generateTaskStages()