edu.iu.dsc.tws.task.cdfw.task

Class ConnectedSource

java.lang.Object

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

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

edu.iu.dsc.tws.task.cdfw.task.ConnectedSource

All Implemented Interfaces:

Closable, Receptor, INode, ISource, java.io.Serializable

public class ConnectedSource
extends BaseSource
implements Receptor

Connected source for the connected dataflow example

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
ConnectedSource()
ConnectedSource(java.lang.String edge)
ConnectedSource(java.lang.String edge, java.lang.String inputkey)

Method Summary

Modifier and Type	Method and Description
void	add(java.lang.String name, DataPartition<?> data)
void	execute() Execute without an incoming message
java.lang.String	getEdge()
IONames	getReceivableNames() This method should return a set of receivable names, that are expected by this receptor.
void	prepare(Config cfg, TaskContext ctx) Prepare the task to be executed
void	setEdge(java.lang.String edge)

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.modifiers.Receptor

add

Constructor Detail

ConnectedSource

public ConnectedSource()

ConnectedSource

public ConnectedSource(java.lang.String edge)

ConnectedSource

public ConnectedSource(java.lang.String edge,
                       java.lang.String inputkey)

Method Detail

execute

public void execute()

Description copied from interface: ISource

Execute without an incoming message

Specified by:

execute in interface ISource

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

getEdge

public java.lang.String getEdge()

setEdge

public void setEdge(java.lang.String edge)

add

public void add(java.lang.String name,
                DataPartition<?> data)

Specified by:

add in interface Receptor

getReceivableNames

public IONames getReceivableNames()

Description copied from interface: Receptor

This method should return a set of receivable names, that are expected by this receptor. These names will be used by task plan builder to cross validate parallelism between two task graphs.

If Collector C of task graph TG1 collects variable "var1" and C's parallelism is n, If Receptor R of task graph TG2 is interested in receiving "var1", R's parallelism should be equal to n and, R should have the same distribution as C among the workers.

Specified by:

getReceivableNames in interface Receptor

Returns:

get the set of names