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

Class SVMCommsReducer

java.lang.Object

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

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

All Implemented Interfaces:

IWorker

public class SVMCommsReducer
extends CommsWorker

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	SVMCommsReducer.FinalSingularReceiver

Nested classes/interfaces inherited from class edu.iu.dsc.tws.examples.ml.svm.comms.CommsWorker

CommsWorker.DataStreamer

Field Summary

Fields inherited from class edu.iu.dsc.tws.examples.ml.svm.comms.CommsWorker

commsType, features, finishedSources, inputDataArray, logicalPlan, parallelism, sourcesDone, svmJobParameters, taskStages, testingSamples, trainingSamples, workerId

Constructor Summary

Constructors

Constructor and Description
SVMCommsReducer()

Method Summary

Modifier and Type	Method and Description
void	close()
protected void	execute(WorkerEnvironment workerEnv)
protected void	finishCommunication(int src)
java.util.List<java.lang.Integer>	generateTaskStages()
protected boolean	isDone()
protected void	progressCommunication()
protected boolean	sendMessages(int task, java.lang.Object data, int flag)

Methods inherited from class edu.iu.dsc.tws.examples.ml.svm.comms.CommsWorker

execute, progress

Methods inherited from class java.lang.Object

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

Constructor Detail

SVMCommsReducer

public SVMCommsReducer()

Method Detail

execute

protected void execute(WorkerEnvironment workerEnv)

Specified by:

execute in class CommsWorker

progressCommunication

protected void progressCommunication()

Specified by:

progressCommunication in class CommsWorker

isDone

protected boolean isDone()

Specified by:

isDone in class CommsWorker

close

public void close()

Overrides:

close in class CommsWorker

sendMessages

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

Specified by:

sendMessages in class CommsWorker

finishCommunication

protected void finishCommunication(int src)

Overrides:

finishCommunication in class CommsWorker

generateTaskStages

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

Specified by:

generateTaskStages in class CommsWorker