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

Class IterativeStreamingCompute

java.lang.Object

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

edu.iu.dsc.tws.api.compute.nodes.BaseCompute<double[]>

edu.iu.dsc.tws.examples.ml.svm.compute.IterativeStreamingCompute

All Implemented Interfaces:

Closable, Collector, Receptor, ICompute<double[]>, INode, ICollector<double[]>, IReceptor<double[][]>, java.io.Serializable

public class IterativeStreamingCompute
extends BaseCompute<double[]>
implements ICollector<double[]>, 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
IterativeStreamingCompute(OperationMode operationMode)
IterativeStreamingCompute(OperationMode operationMode, IFunction<double[]> reduceFn)
IterativeStreamingCompute(OperationMode operationMode, IFunction<double[]> reduceFn, SVMJobParameters svmJobParameters)

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	evaluateModel(double[] w, int evalCount)
boolean	execute(IMessage<double[]> message) Execute with an incoming message
DataPartition<double[]>	get() get the collected valued
void	prepare(Config cfg, TaskContext ctx) Prepare the task to be executed

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

close, 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.examples.ml.svm.integration.test.ICollector

get

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

getCollectibleNames

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

endExecute

Constructor Detail

IterativeStreamingCompute

public IterativeStreamingCompute(OperationMode operationMode)

IterativeStreamingCompute

public IterativeStreamingCompute(OperationMode operationMode,
                                 IFunction<double[]> reduceFn)

IterativeStreamingCompute

public IterativeStreamingCompute(OperationMode operationMode,
                                 IFunction<double[]> reduceFn,
                                 SVMJobParameters svmJobParameters)

Method Detail

prepare

public void prepare(Config cfg,
                    TaskContext ctx)

Description copied from interface: INode

Prepare the task to be executed

Specified by:

prepare in interface INode

Overrides:

prepare in class BaseNode

Parameters:

cfg - the configuration

ctx - the task context, this has runtime information about the task

get

public DataPartition<double[]> get()

Description copied from interface: ICollector

get the collected valued

Specified by:

get in interface Collector

Specified by:

get in interface ICollector<double[]>

Returns:

get the default output

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 boolean execute(IMessage<double[]> message)

Description copied from interface: ICompute

Execute with an incoming message

Specified by:

execute in interface ICompute<double[]>

evaluateModel

public void evaluateModel(double[] w,
                          int evalCount)