Constructor and Description |
---|
PersistentConnectionToMasterMap(MessageEnvironment messageEnvironment) |
Modifier and Type | Class and Description |
---|---|
class |
GrpcMessageEnvironment
This class is installed when every node, containing both driver and evaluator, has been started, and setup
grpc environment to implement RPC semantics defined in
edu.snu.coral.runtime.common.message package. |
Modifier and Type | Class and Description |
---|---|
class |
LocalMessageEnvironment
A simple
MessageEnvironment implementation that works on a single node. |
Modifier and Type | Class and Description |
---|---|
class |
NcsMessageEnvironment
Message environment for NCS.
|
Constructor and Description |
---|
Executor(String executorId,
int executorCapacity,
PersistentConnectionToMasterMap persistentConnectionToMasterMap,
MessageEnvironment messageEnvironment,
CoderManager coderManager,
DataTransferFactory dataTransferFactory,
MetricManagerWorker metricMessageSender) |
Constructor and Description |
---|
RuntimeMaster(Scheduler scheduler,
SchedulerRunner schedulerRunner,
PendingTaskGroupQueue pendingTaskGroupQueue,
ContainerManager containerManager,
BlockManagerMaster blockManagerMaster,
MetricMessageHandler metricMessageHandler,
MessageEnvironment masterMessageEnvironment,
String dagDirectory) |
Constructor and Description |
---|
ContainerManager(int scheduleSerThread,
org.apache.reef.driver.evaluator.EvaluatorRequestor evaluatorRequestor,
MessageEnvironment messageEnvironment) |
Copyright © 2018. All rights reserved.