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

Class IterativeDataStream

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.streamer.IterativeDataStream

All Implemented Interfaces:

Closable, Receptor, INode, ISource, IReceptor<double[][]>, java.io.Serializable

public class IterativeDataStream
extends BaseSource
implements IReceptor<double[][]>

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
IterativeDataStream(int features, OperationMode operationMode)
IterativeDataStream(int features, OperationMode operationMode, boolean isDummy, BinaryBatchModel binaryBatchModel)
IterativeDataStream(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	compute()
void	dummyDataStreamer() This method is used to deal with dummy data based data stream generation Here data points are generated using a Gaussian Distribution and labels are assigned +1 or -1 randomly for a given data point.
void	execute() Execute without an incoming message
void	getData()
void	initializeBatchMode() This method initializes the parameters needed to run the batch mode algorithm This method is called per a received batch
void	initializeBinaryModel(double[][] xy) Binary Model is updated with received batch data
void	realDataStreamer() This method is used to retrieve real data from Data Source Task

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

IterativeDataStream

public IterativeDataStream(OperationMode operationMode)

IterativeDataStream

public IterativeDataStream(int features,
                           OperationMode operationMode)

IterativeDataStream

public IterativeDataStream(int features,
                           OperationMode operationMode,
                           boolean isDummy,
                           BinaryBatchModel binaryBatchModel)

Method Detail

add

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

Description copied from interface: IReceptor

This method is called when the data is available

Specified by:

add in interface Receptor

Specified by:

add in interface IReceptor<double[][]>

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

getData

public void getData()

dummyDataStreamer

public void dummyDataStreamer()
                       throws InputDataFormatException

This method is used to deal with dummy data based data stream generation Here data points are generated using a Gaussian Distribution and labels are assigned +1 or -1 randomly for a given data point.

Throws:

InputDataFormatException

realDataStreamer

public void realDataStreamer()

This method is used to retrieve real data from Data Source Task

compute

public void compute()

initializeBatchMode

public void initializeBatchMode()

This method initializes the parameters needed to run the batch mode algorithm This method is called per a received batch

initializeBinaryModel

public void initializeBinaryModel(double[][] xy)

Binary Model is updated with received batch data

Parameters:

xy - data points included with label and features