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.
|
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.
|
Copyright © 2017 The Apache Software Foundation. All rights reserved.