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

Class SVMDataObjectSource<T,O extends InputSplit<T>>

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.data.SVMDataObjectSource<T,O>

All Implemented Interfaces:

Closable, INode, ISource, java.io.Serializable

public class SVMDataObjectSource<T,O extends InputSplit<T>>
extends BaseSource

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
SVMDataObjectSource(java.lang.String edgeName, java.lang.String dataDirectory)
SVMDataObjectSource(java.lang.String edgeName, java.lang.String dataDirectory, int dsize)

Method Summary

Modifier and Type	Method and Description
void	execute() Execute without an incoming message
java.lang.String	getDataDirectory()
java.lang.String	getEdgeName()
void	prepare(Config cfg, TaskContext ctx) Prepare the task to be executed
void	setDataDirectory(java.lang.String dataDirectory)
void	setEdgeName(java.lang.String edgeName)

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

Constructor Detail

SVMDataObjectSource

public SVMDataObjectSource(java.lang.String edgeName,
                           java.lang.String dataDirectory)

SVMDataObjectSource

public SVMDataObjectSource(java.lang.String edgeName,
                           java.lang.String dataDirectory,
                           int dsize)

Method Detail

getEdgeName

public java.lang.String getEdgeName()

setEdgeName

public void setEdgeName(java.lang.String edgeName)

getDataDirectory

public java.lang.String getDataDirectory()

setDataDirectory

public void setDataDirectory(java.lang.String dataDirectory)

execute

public void execute()

Description copied from interface: ISource

Execute without an incoming message

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