edu.iu.dsc.tws.task.dataobjects

Class DataFileReplicatedReadSource

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

All Implemented Interfaces:

Closable, INode, ISource, java.io.Serializable

public class DataFileReplicatedReadSource
extends BaseSource

This class partition the datapoints using the LocalCompleteTextInputPartitioner to partition the complete file as a one partition.

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
DataFileReplicatedReadSource()
DataFileReplicatedReadSource(java.lang.String edgename, java.lang.String directory)
DataFileReplicatedReadSource(java.lang.String edgename, java.lang.String directory, int dSize)

Method Summary

Modifier and Type	Method and Description
void	execute() It uses the LocalCompleteTextInputPartitioner to partition and read the whole file and write those values into the respective task index values.
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

DataFileReplicatedReadSource

public DataFileReplicatedReadSource(java.lang.String edgename,
                                    java.lang.String directory)

DataFileReplicatedReadSource

public DataFileReplicatedReadSource(java.lang.String edgename,
                                    java.lang.String directory,
                                    int dSize)

DataFileReplicatedReadSource

public DataFileReplicatedReadSource()

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()

It uses the LocalCompleteTextInputPartitioner to partition and read the whole file and write those values into the respective task index values.

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