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

Class TopologyUpdateWaitHandler

java.lang.Object

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

All Implemented Interfaces:

EventHandler<List<TaskNode>>

public class TopologyUpdateWaitHandler
extends Object
implements EventHandler<List<TaskNode>>

Constructor Summary

Constructors

Constructor and Description
TopologyUpdateWaitHandler(EStage<GroupCommunicationMessage> senderStage, Class<? extends Name<String>> groupName, Class<? extends Name<String>> operName, String driverId, int driverVersion, String dstId, int dstVersion, String qualifiedName, byte[] data) The handler will wait for all nodes to acquire topoLock and send TopologySetup msg.

Method Summary

Methods

Modifier and Type	Method and Description
void	onNext(List<TaskNode> nodes) Handles an event.

Methods inherited from class java.lang.Object

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

Constructor Detail

TopologyUpdateWaitHandler

public TopologyUpdateWaitHandler(EStage<GroupCommunicationMessage> senderStage,
                         Class<? extends Name<String>> groupName,
                         Class<? extends Name<String>> operName,
                         String driverId,
                         int driverVersion,
                         String dstId,
                         int dstVersion,
                         String qualifiedName,
                         byte[] data)

The handler will wait for all nodes to acquire topoLock and send TopologySetup msg. Then it will send TopologyUpdated msg. However, any local topology changes are not in effect till driver sends TopologySetup once statusMap is emptied The operations in the tasks that have topology changes will wait for this. However other tasks that do not have any changes will continue their regular operation

Method Detail

onNext

public void onNext(List<TaskNode> nodes)

Description copied from interface: EventHandler

Handles an event.

Specified by:

onNext in interface EventHandler<List<TaskNode>>

Parameters:

nodes - an event