edu.iu.dsc.tws.api.compute.graph

Class Edge

java.lang.Object

edu.iu.dsc.tws.api.compute.graph.Edge

public class Edge
extends java.lang.Object

Represents a edge in the graph

Constructor Summary

Constructors

Constructor and Description
Edge()
Edge(java.lang.String te)
Edge(java.lang.String taskEdge, IFunction function)
Edge(java.lang.String name, java.lang.String operation)
Edge(java.lang.String name, java.lang.String operation, IFunction function)
Edge(java.lang.String name, java.lang.String operation, MessageType dataType)
Edge(java.lang.String name, java.lang.String operation, MessageType dataType, IFunction function)
Edge(java.lang.String name, java.lang.String operation, MessageType dataType, MessageType keyType)
Edge(java.lang.String name, java.lang.String operation, MessageType dataType, MessageType keyType, IFunction function)
Edge(java.lang.String name, java.lang.String operation, MessageType dataType, MessageType keyType, IFunction function, TaskPartitioner part)

Method Summary

Modifier and Type	Method and Description
void	addProperties(java.util.Map<java.lang.String,java.lang.Object> props) Add the properties to the edge
void	addProperty(java.lang.String key, java.lang.Object value) Add a property to the edge
MessageType	getDataType() To get the datatype
EdgeID	getEdgeID()
int	getEdgeIndex()
IFunction	getFunction() To get the IFunction object.
MessageType	getKeyType() To get the keytype
MessageSchema	getMessageSchema()
java.lang.String	getName() To get the name of the task edge
int	getNumberOfEdges()
java.lang.String	getOperation() To get the operation name
TaskPartitioner	getPartitioner() Get the partitioner
java.util.Map<java.lang.String,java.lang.Object>	getProperties()
java.lang.Object	getProperty(java.lang.String key) Get the property with a specific key
java.lang.String	getTargetEdge() Get the group name, if the group is set, multiple edges can belong to a same group
boolean	isKeyed()
void	setDataType(MessageType dataType)
void	setEdgeIndex(int edgeIndex)
void	setFunction(IFunction function)
void	setKeyed(boolean keyed)
void	setKeyType(MessageType keyType)
void	setMessageSchema(MessageSchema messageSchema)
void	setName(java.lang.String name)
void	setNumberOfEdges(int numberOfEdges)
void	setOperation(java.lang.String operation)
void	setPartitioner(TaskPartitioner partitioner)
void	setProperties(java.util.Map<java.lang.String,java.lang.Object> properties)
void	setTargetEdge(java.lang.String targetEdge)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Edge

public Edge()

Edge

public Edge(java.lang.String te)

Edge

public Edge(java.lang.String name,
            java.lang.String operation)

Edge

public Edge(java.lang.String taskEdge,
            IFunction function)

Edge

public Edge(java.lang.String name,
            java.lang.String operation,
            MessageType dataType)

Edge

public Edge(java.lang.String name,
            java.lang.String operation,
            IFunction function)

Edge

public Edge(java.lang.String name,
            java.lang.String operation,
            MessageType dataType,
            MessageType keyType)

Edge

public Edge(java.lang.String name,
            java.lang.String operation,
            MessageType dataType,
            MessageType keyType,
            IFunction function)

Edge

public Edge(java.lang.String name,
            java.lang.String operation,
            MessageType dataType,
            IFunction function)

Edge

public Edge(java.lang.String name,
            java.lang.String operation,
            MessageType dataType,
            MessageType keyType,
            IFunction function,
            TaskPartitioner part)

Method Detail

setMessageSchema

public void setMessageSchema(MessageSchema messageSchema)

getMessageSchema

public MessageSchema getMessageSchema()

getName

public java.lang.String getName()

To get the name of the task edge

getFunction

public IFunction getFunction()

To get the IFunction object.

getOperation

public java.lang.String getOperation()

To get the operation name

getDataType

public MessageType getDataType()

To get the datatype

getKeyType

public MessageType getKeyType()

To get the keytype

isKeyed

public boolean isKeyed()

addProperty

public void addProperty(java.lang.String key,
                        java.lang.Object value)

Add a property to the edge

Parameters:

key - key of the property

value - value

getProperty

public java.lang.Object getProperty(java.lang.String key)

Get the property with a specific key

Parameters:

key - name of the property

Returns:

property if exists and null if not

addProperties

public void addProperties(java.util.Map<java.lang.String,java.lang.Object> props)

Add the properties to the edge

Parameters:

props - properties

getPartitioner

public TaskPartitioner getPartitioner()

Get the partitioner

Returns:

partitioner

setName

public void setName(java.lang.String name)

setFunction

public void setFunction(IFunction function)

setPartitioner

public void setPartitioner(TaskPartitioner partitioner)

setOperation

public void setOperation(java.lang.String operation)

setDataType

public void setDataType(MessageType dataType)

setKeyType

public void setKeyType(MessageType keyType)

setKeyed

public void setKeyed(boolean keyed)

getProperties

public java.util.Map<java.lang.String,java.lang.Object> getProperties()

setProperties

public void setProperties(java.util.Map<java.lang.String,java.lang.Object> properties)

getTargetEdge

public java.lang.String getTargetEdge()

Get the group name, if the group is set, multiple edges can belong to a same group

Returns:

the group

setTargetEdge

public void setTargetEdge(java.lang.String targetEdge)

setEdgeIndex

public void setEdgeIndex(int edgeIndex)

setNumberOfEdges

public void setNumberOfEdges(int numberOfEdges)

getEdgeIndex

public int getEdgeIndex()

getNumberOfEdges

public int getNumberOfEdges()

getEdgeID

public EdgeID getEdgeID()