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

Class IterativeStreamingDataStreamer

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.IterativeStreamingDataStreamer

All Implemented Interfaces:

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

public class IterativeStreamingDataStreamer
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
IterativeStreamingDataStreamer(int features, OperationMode operationMode)
IterativeStreamingDataStreamer(int features, OperationMode operationMode, boolean isDummy, BinaryBatchModel binaryBatchModel)
IterativeStreamingDataStreamer(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	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	realDataStreamer() This method is used to retrieve real data from Data Source Task
void	streamData()

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

IterativeStreamingDataStreamer

public IterativeStreamingDataStreamer(OperationMode operationMode)

IterativeStreamingDataStreamer

public IterativeStreamingDataStreamer(int features,
                                      OperationMode operationMode)

IterativeStreamingDataStreamer

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

Method Detail

execute

public void execute()

Description copied from interface: ISource

Execute without an incoming message

Specified by:

execute in interface ISource

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

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

streamData

public void streamData()