| Package | Description |
|---|---|
| org.apache.reef.examples.group.bgd |
Runs BGD on the given runtime.
|
| org.apache.reef.examples.group.broadcast |
Broadcast Group Communication example.
|
| 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.
|
| org.apache.reef.io.network.group.impl.task |
Implementations for Elastic Group Communications Task-side API.
|
| org.apache.reef.runtime.common.driver.context |
Implementations of Driver-Side representations of Contexts running on an Evaluator.
|
| org.apache.reef.tang.formats |
Tang format classes encode and decode information that Tang gathers at
runtime.
|
| Constructor and Description |
|---|
BGDDriver(DataLoadingService dataLoadingService,
GroupCommDriver groupCommDriver,
ConfigurationSerializer confSerializer,
BGDControlParameters bgdControlParameters) |
| Constructor and Description |
|---|
BroadcastDriver(EvaluatorRequestor requestor,
GroupCommDriver groupCommDriver,
ConfigurationSerializer confSerializer,
int dimensions,
int numberOfReceivers) |
| 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.
|
GroupCommDriverImpl(ConfigurationSerializer confSerializer,
String driverId,
int fanOut,
LocalAddressProvider localAddressProvider,
TransportFactory tpFactory,
NameServer nameService)
Deprecated.
in 0.12. Use Tang to obtain an instance of this instead.
|
| Constructor and Description |
|---|
CommunicationGroupClientImpl(String groupName,
String taskId,
String driverId,
GroupCommNetworkHandler groupCommNetworkHandler,
Set<String> operatorConfigs,
ConfigurationSerializer configSerializer,
NetworkService<GroupCommunicationMessage> netService)
Deprecated.
in 0.14.
Use the private constructor that receives an
injector as a parameter instead. |
GroupCommClientImpl(Set<String> groupConfigs,
String taskId,
GroupCommNetworkHandler groupCommNetworkHandler,
NetworkService<ReefNetworkGroupCommProtos.GroupCommMessage> netService,
ConfigurationSerializer configSerializer)
Deprecated.
in 0.14.
Use the other constructor that receives an
injector as a parameter instead.
The parameters taskId and netService can be removed from the other constructor when
this constructor gets deleted. |
| Constructor and Description |
|---|
EvaluatorContext(String contextIdentifier,
String evaluatorIdentifier,
EvaluatorDescriptor evaluatorDescriptor,
Optional<String> parentID,
ConfigurationSerializer configurationSerializer,
ContextControlHandler contextControlHandler,
EvaluatorMessageDispatcher messageDispatcher,
ExceptionCodec exceptionCodec,
ContextRepresenters contextRepresenters) |
| Modifier and Type | Class and Description |
|---|---|
class |
AvroConfigurationSerializer
(De-)Serializing Configuration to and from AvroConfiguration.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.