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

Class PredictionSourceTask

java.lang.Object

edu.iu.dsc.tws.api.compute.nodes.BaseNode

edu.iu.dsc.tws.api.compute.nodes.BaseSource

edu.iu.dsc.tws.examples.ml.svm.test.PredictionSourceTask

All Implemented Interfaces:

Closable, Receptor, INode, ISource, java.io.Serializable

public class PredictionSourceTask
extends BaseSource
implements Receptor

See Also:

Serialized Form

Field Summary

Fields inherited from class edu.iu.dsc.tws.api.compute.nodes.BaseNode

config, context

Constructor Summary

Constructors

Constructor and Description
PredictionSourceTask(boolean isDummy, BinaryBatchModel binaryBatchModel, OperationMode operationMode)

Method Summary

Modifier and Type	Method and Description
void	add(java.lang.String name, DataObject<?> data) This method is called when the data is available
void	doPrediction()
void	dummyTest()
void	execute() Execute without an incoming message
void	getData() This method must be broken down to smaller parts
java.lang.Object	getDataPointsByDataObject(int taskIndex, DataObject<?> datapointsDataObject)
java.lang.Object	getDataPointsByTaskIndex(int taskIndex)
java.lang.Object	getWeightVectorByTaskIndex(int taskIndex)
java.lang.Object	getWeightVectorByWeightVectorObject(int taskIndex, DataObject<?> datapointsDataObject)
void	realTest()

Methods inherited from class edu.iu.dsc.tws.api.compute.nodes.BaseNode

close, prepare, reset

Methods inherited from class java.lang.Object

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

Methods inherited from interface edu.iu.dsc.tws.api.compute.modifiers.Receptor

add, getReceivableNames

Methods inherited from interface edu.iu.dsc.tws.api.compute.nodes.INode

prepare

Constructor Detail

PredictionSourceTask

public PredictionSourceTask(boolean isDummy,
                            BinaryBatchModel binaryBatchModel,
                            OperationMode operationMode)

Method Detail

add

public void add(java.lang.String name,
                DataObject<?> data)

Description copied from interface: Receptor

This method is called when the data is available

Specified by:

add in interface Receptor

Parameters:

name - name of the input

data - input data

execute

public void execute()

Description copied from interface: ISource

Execute without an incoming message

Specified by:

execute in interface ISource

dummyTest

public void dummyTest()

realTest

public void realTest()
              throws MatrixMultiplicationException

Throws:

MatrixMultiplicationException

getDataPointsByTaskIndex

public java.lang.Object getDataPointsByTaskIndex(int taskIndex)

getDataPointsByDataObject

public java.lang.Object getDataPointsByDataObject(int taskIndex,
                                                  DataObject<?> datapointsDataObject)

getWeightVectorByTaskIndex

public java.lang.Object getWeightVectorByTaskIndex(int taskIndex)

getWeightVectorByWeightVectorObject

public java.lang.Object getWeightVectorByWeightVectorObject(int taskIndex,
                                                            DataObject<?> datapointsDataObject)

getData

public void getData()
             throws MatrixMultiplicationException

This method must be broken down to smaller parts

Throws:

MatrixMultiplicationException

doPrediction

public void doPrediction()
                  throws MatrixMultiplicationException

Throws:

MatrixMultiplicationException