org.apache.reef.io.network.group.impl.driver

Class FlatTopology

java.lang.Object

org.apache.reef.io.network.group.impl.driver.FlatTopology

All Implemented Interfaces:

Topology

public class FlatTopology
extends Object
implements Topology

Implements a one level Tree Topology.

Constructor Summary

Constructors

Constructor and Description
FlatTopology(EStage<GroupCommunicationMessage> senderStage, Class<? extends Name<String>> groupName, Class<? extends Name<String>> operatorName, String driverId, int numberOfTasks) Deprecated. in 0.14. Use Tang to obtain an instance of this instead.

Method Summary

Methods

Modifier and Type	Method and Description
void	addTask(String taskId) Add task with id 'taskId' to.
int	getNodeVersion(String taskId) Get the version of the Task 'taskId'.
String	getRootId() Get the id of the root task.
Configuration	getTaskConfiguration(String taskId) Get the topology portion of the Configuration.
boolean	isRootPresent() Check whether the root node has been added or not.
void	onFailedTask(String id) Update state on receipt of FailedTask.
void	onReceiptOfMessage(GroupCommunicationMessage msg) Update state on receipt of a message.
void	onRunningTask(String id) Update state on receipt of RunningTask.
void	removeTask(String taskId) Remove task with id 'taskId' from.
void	setOperatorSpecification(OperatorSpec spec) Set operator specification of the operator.
void	setRootTask(String rootId) Set task with id 'senderId' as.

Methods inherited from class java.lang.Object

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

Constructor Detail

FlatTopology

@Deprecated
public FlatTopology(EStage<GroupCommunicationMessage> senderStage,
                       Class<? extends Name<String>> groupName,
                       Class<? extends Name<String>> operatorName,
                       String driverId,
                       int numberOfTasks)

Deprecated. in 0.14. Use Tang to obtain an instance of this instead.

Method Detail

setRootTask

public void setRootTask(String rootId)

Description copied from interface: Topology

Set task with id 'senderId' as. the root of this topology

Specified by:

setRootTask in interface Topology

getRootId

public String getRootId()

Description copied from interface: Topology

Get the id of the root task.

Specified by:

getRootId in interface Topology

Returns:

the rootId

isRootPresent

public boolean isRootPresent()

Description copied from interface: Topology

Check whether the root node has been added or not.

Specified by:

isRootPresent in interface Topology

Returns:

true if root has been added, false otherwise

setOperatorSpecification

public void setOperatorSpecification(OperatorSpec spec)

Description copied from interface: Topology

Set operator specification of the operator. that is the owner of this topology instance

Specified by:

setOperatorSpecification in interface Topology

getTaskConfiguration

public Configuration getTaskConfiguration(String taskId)

Description copied from interface: Topology

Get the topology portion of the Configuration. for the task 'taskId' that belongs to this topology

Specified by:

getTaskConfiguration in interface Topology

Returns:

getNodeVersion

public int getNodeVersion(String taskId)

Description copied from interface: Topology

Get the version of the Task 'taskId'. that belongs to this topology

Specified by:

getNodeVersion in interface Topology

Returns:

removeTask

public void removeTask(String taskId)

Description copied from interface: Topology

Remove task with id 'taskId' from. the topology

Specified by:

removeTask in interface Topology

addTask

public void addTask(String taskId)

Description copied from interface: Topology

Add task with id 'taskId' to. the topology

Specified by:

addTask in interface Topology

onFailedTask

public void onFailedTask(String id)

Description copied from interface: Topology

Update state on receipt of FailedTask. event for task with id 'id'

Specified by:

onFailedTask in interface Topology

onRunningTask

public void onRunningTask(String id)

Description copied from interface: Topology

Update state on receipt of RunningTask. event for task with id 'id'

Specified by:

onRunningTask in interface Topology

onReceiptOfMessage

public void onReceiptOfMessage(GroupCommunicationMessage msg)

Description copied from interface: Topology

Update state on receipt of a message. from the tasks

Specified by:

onReceiptOfMessage in interface Topology