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.runtime.common.driver.context |
Implementations of Driver-Side representations of Contexts running on an Evaluator.
|
org.apache.reef.tang |
Public interfaces and factories for Tang's core API.
|
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.
|
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 | Method and Description |
---|---|
static ConfigurationSerializer |
Configurations.getDefaultSerializer()
Get the default configuration serializer.
|
Modifier and Type | Class and Description |
---|---|
class |
AvroConfigurationSerializer
(De-)Serializing Configuration to and from AvroConfiguration.
|
Copyright © 2017 The Apache Software Foundation. All rights reserved.