edu.iu.dsc.tws.task.dataobjects

Class DataObjectCSVSource

java.lang.Object

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

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

edu.iu.dsc.tws.task.dataobjects.DataObjectCSVSource

All Implemented Interfaces:

Closable, INode, ISource, java.io.Serializable

public class DataObjectCSVSource
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
DataObjectCSVSource()
DataObjectCSVSource(java.lang.String edgename, java.lang.String dataDirectory)

Method Summary

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

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

DataObjectCSVSource

public DataObjectCSVSource()

DataObjectCSVSource

public DataObjectCSVSource(java.lang.String edgename,
                           java.lang.String dataDirectory)

Method Detail

getDataDirectory

public java.lang.String getDataDirectory()

setDataDirectory

public void setDataDirectory(java.lang.String dataDirectory)

getEdgeName

public java.lang.String getEdgeName()

Getter property to set the edge name

setEdgeName

public void setEdgeName(java.lang.String edgeName)

Setter property to set the edge name

execute

public void execute()

Description copied from interface: ISource

Execute without an incoming message

prepare

public void prepare(Config cfg,
                    TaskContext context)

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

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