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

Class IterativeSVMWeightVectorObjectCompute

java.lang.Object

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

edu.iu.dsc.tws.api.compute.nodes.BaseCompute<java.util.Iterator<T>>

edu.iu.dsc.tws.task.typed.AbstractIterableDataCompute<java.lang.String>

edu.iu.dsc.tws.examples.ml.svm.data.IterativeSVMWeightVectorObjectCompute

All Implemented Interfaces:

Closable, ICompute<java.util.Iterator<java.lang.String>>, INode, java.io.Serializable

public class IterativeSVMWeightVectorObjectCompute
extends AbstractIterableDataCompute<java.lang.String>

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
IterativeSVMWeightVectorObjectCompute(java.lang.String edgeName, int datasize, int features)
IterativeSVMWeightVectorObjectCompute(java.lang.String edgeName, int parallelism, int datasize, int features)

Method Summary

Modifier and Type	Method and Description
boolean	execute(IMessage<java.util.Iterator<java.lang.String>> message) Execute with an incoming message
int	getDatasize()
java.lang.String	getEdgeName()
int	getFeatures()
int	getParallelism()
void	prepare(Config cfg, TaskContext ctx) Prepare the task to be executed
void	setDatasize(int datasize)
void	setEdgeName(java.lang.String edgeName)
void	setFeatures(int features)
void	setParallelism(int parallelism)

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.api.compute.nodes.ICompute

endExecute

Constructor Detail

IterativeSVMWeightVectorObjectCompute

public IterativeSVMWeightVectorObjectCompute(java.lang.String edgeName,
                                             int parallelism,
                                             int datasize,
                                             int features)

IterativeSVMWeightVectorObjectCompute

public IterativeSVMWeightVectorObjectCompute(java.lang.String edgeName,
                                             int datasize,
                                             int features)

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

getEdgeName

public java.lang.String getEdgeName()

setEdgeName

public void setEdgeName(java.lang.String edgeName)

getParallelism

public int getParallelism()

setParallelism

public void setParallelism(int parallelism)

getDatasize

public int getDatasize()

setDatasize

public void setDatasize(int datasize)

getFeatures

public int getFeatures()

setFeatures

public void setFeatures(int features)

execute

public boolean execute(IMessage<java.util.Iterator<java.lang.String>> message)

Description copied from interface: ICompute

Execute with an incoming message