Uses of Class
org.apache.reef.io.network.group.impl.utils.BroadcastingEventHandler

Packages that use BroadcastingEventHandler

Package	Description
org.apache.reef.io.network.group.impl.driver	This package contains the implementation of the driver side of the Group Communication Service using the tree/flat topology.

Uses of BroadcastingEventHandler in org.apache.reef.io.network.group.impl.driver

Methods in org.apache.reef.io.network.group.impl.driver with parameters of type BroadcastingEventHandler

Modifier and Type	Method and Description
void	GroupCommMessageHandler.addHandler(Class<? extends Name<String>> groupName, BroadcastingEventHandler<GroupCommunicationMessage> handler) Deprecated. in 0.14.
CommunicationGroupDriver	CommunicationGroupDriverFactory.getNewInstance(Class<? extends Name<String>> groupName, Class<? extends Topology> topologyClass, BroadcastingEventHandler<GroupCommunicationMessage> commGroupMessageHandler, int numberOfTasks, int customFanOut) Deprecated. in 0.14. Instantiates a new CommunicationGroupDriver instance.

Constructors in org.apache.reef.io.network.group.impl.driver with parameters of type BroadcastingEventHandler

Constructor and Description
CommunicationGroupDriverImpl(Class<? extends Name<String>> groupName, ConfigurationSerializer confSerializer, EStage<GroupCommunicationMessage> senderStage, BroadcastingEventHandler<RunningTask> groupCommRunningTaskHandler, BroadcastingEventHandler<FailedTask> groupCommFailedTaskHandler, BroadcastingEventHandler<FailedEvaluator> groupCommFailedEvaluatorHandler, BroadcastingEventHandler<GroupCommunicationMessage> commGroupMessageHandler, String driverId, int numberOfTasks, int fanOut) Deprecated. in 0.14. Use Tang to obtain an instance of this instead.
CommunicationGroupDriverImpl(Class<? extends Name<String>> groupName, ConfigurationSerializer confSerializer, EStage<GroupCommunicationMessage> senderStage, BroadcastingEventHandler<RunningTask> groupCommRunningTaskHandler, BroadcastingEventHandler<FailedTask> groupCommFailedTaskHandler, BroadcastingEventHandler<FailedEvaluator> groupCommFailedEvaluatorHandler, BroadcastingEventHandler<GroupCommunicationMessage> commGroupMessageHandler, String driverId, int numberOfTasks, int fanOut) Deprecated. in 0.14. Use Tang to obtain an instance of this instead.
CommunicationGroupDriverImpl(Class<? extends Name<String>> groupName, ConfigurationSerializer confSerializer, EStage<GroupCommunicationMessage> senderStage, BroadcastingEventHandler<RunningTask> groupCommRunningTaskHandler, BroadcastingEventHandler<FailedTask> groupCommFailedTaskHandler, BroadcastingEventHandler<FailedEvaluator> groupCommFailedEvaluatorHandler, BroadcastingEventHandler<GroupCommunicationMessage> commGroupMessageHandler, String driverId, int numberOfTasks, int fanOut) Deprecated. in 0.14. Use Tang to obtain an instance of this instead.
CommunicationGroupDriverImpl(Class<? extends Name<String>> groupName, ConfigurationSerializer confSerializer, EStage<GroupCommunicationMessage> senderStage, BroadcastingEventHandler<RunningTask> groupCommRunningTaskHandler, BroadcastingEventHandler<FailedTask> groupCommFailedTaskHandler, BroadcastingEventHandler<FailedEvaluator> groupCommFailedEvaluatorHandler, BroadcastingEventHandler<GroupCommunicationMessage> commGroupMessageHandler, String driverId, int numberOfTasks, int fanOut) Deprecated. in 0.14. Use Tang to obtain an instance of this instead.