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

Class InputDataStreamer

java.lang.Object

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

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

All Implemented Interfaces:

IWorker

public class InputDataStreamer
extends CommsWorker

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	InputDataStreamer.DirectReceiver

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
InputDataStreamer()

Method Summary

Modifier and Type	Method and Description
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

close, execute, progress

Methods inherited from class java.lang.Object

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

Constructor Detail

InputDataStreamer

public InputDataStreamer()

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

sendMessages

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

Specified by:

sendMessages in class CommsWorker

generateTaskStages

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

Specified by:

generateTaskStages in class CommsWorker

finishCommunication

protected void finishCommunication(int src)

Overrides:

finishCommunication in class CommsWorker