public class TopologyUpdateWaitHandler extends Object implements EventHandler<List<TaskNode>>
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.
|
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)
public void onNext(List<TaskNode> nodes)
EventHandler
onNext
in interface EventHandler<List<TaskNode>>
nodes
- an eventCopyright © 2017 The Apache Software Foundation. All rights reserved.