edu.iu.dsc.tws.graphapi.api

Class BasicComputation.GraphInitialization

java.lang.Object

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

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

edu.iu.dsc.tws.graphapi.api.ConstructDataStr

edu.iu.dsc.tws.graphapi.api.BasicComputation.GraphInitialization

All Implemented Interfaces:

Closable, ICompute, INode, java.io.Serializable

Enclosing class:

BasicComputation

public abstract class BasicComputation.GraphInitialization
extends ConstructDataStr

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
GraphInitialization(java.lang.String edgename, int dsize, int parallel)

Method Summary

Modifier and Type	Method and Description
abstract void	constructDataStr(java.util.HashMap<java.lang.String,VertexStatus> hashMap, IMessage message)
boolean	execute(IMessage message) Execute with an incoming message
void	writeMsgOnEdge(java.lang.String edgeName, java.util.HashMap<java.lang.String,VertexStatus> hashMap)

Methods inherited from class edu.iu.dsc.tws.graphapi.api.ConstructDataStr

getDatasize, getEdgeName, getParallel, prepare, setDatasize, setEdgeName, setParallel

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

GraphInitialization

public GraphInitialization(java.lang.String edgename,
                           int dsize,
                           int parallel)

Method Detail

constructDataStr

public abstract void constructDataStr(java.util.HashMap<java.lang.String,VertexStatus> hashMap,
                                      IMessage message)

writeMsgOnEdge

public void writeMsgOnEdge(java.lang.String edgeName,
                           java.util.HashMap<java.lang.String,VertexStatus> hashMap)

execute

public boolean execute(IMessage message)

Description copied from interface: ICompute

Execute with an incoming message