| Package | Description |
|---|---|
| org.apache.reef.driver.context | |
| org.apache.reef.driver.evaluator | |
| org.apache.reef.runtime.common.driver.context |
Implementations of Driver-Side representations of Contexts running on an Evaluator
|
| org.apache.reef.runtime.common.driver.evaluator |
Driver-Side representations of Evaluators.
|
| org.apache.reef.webserver |
| Modifier and Type | Method and Description |
|---|---|
EvaluatorDescriptor |
ContextBase.getEvaluatorDescriptor() |
| Modifier and Type | Method and Description |
|---|---|
EvaluatorDescriptor |
AllocatedEvaluator.getEvaluatorDescriptor() |
| Modifier and Type | Method and Description |
|---|---|
EvaluatorDescriptor |
FailedContextImpl.getEvaluatorDescriptor() |
EvaluatorDescriptor |
ClosedContextImpl.getEvaluatorDescriptor() |
EvaluatorDescriptor |
EvaluatorContext.getEvaluatorDescriptor() |
| Constructor and Description |
|---|
ClosedContextImpl(ActiveContext parentContext,
String contextID,
String evaluatorId,
EvaluatorDescriptor evaluatorDescriptor) |
EvaluatorContext(String contextIdentifier,
String evaluatorIdentifier,
EvaluatorDescriptor evaluatorDescriptor,
Optional<String> parentID,
ConfigurationSerializer configurationSerializer,
ContextControlHandler contextControlHandler,
EvaluatorMessageDispatcher messageDispatcher,
ExceptionCodec exceptionCodec,
ContextRepresenters contextRepresenters) |
FailedContextImpl(String id,
String message,
Optional<String> description,
Optional<Throwable> cause,
Optional<byte[]> data,
Optional<ActiveContext> parentContext,
EvaluatorDescriptor evaluatorDescriptor,
String evaluatorID) |
| Modifier and Type | Method and Description |
|---|---|
EvaluatorDescriptor |
EvaluatorManager.getEvaluatorDescriptor() |
| Modifier and Type | Method and Description |
|---|---|
EvaluatorDescriptor |
ReefEventStateManager.get(String key)
get a value from evaluators by key
|
EvaluatorDescriptor |
ReefEventStateManager.getEvaluatorDescriptor(String evaluatorId)
getEvaluatorDescriptor
|
| Modifier and Type | Method and Description |
|---|---|
Map<String,EvaluatorDescriptor> |
ReefEventStateManager.getEvaluators()
get evaluator map
|
| Modifier and Type | Method and Description |
|---|---|
void |
ReefEventStateManager.put(String key,
EvaluatorDescriptor value)
pus a entry to evaluators
|
| Modifier and Type | Method and Description |
|---|---|
AvroEvaluatorsInfo |
EvaluatorInfoSerializer.toAvro(List<String> ids,
Map<String,EvaluatorDescriptor> evaluators)
Build AvroEvaluatorsInfo object from raw data
|
AvroEvaluatorsInfo |
AvroEvaluatorInfoSerializer.toAvro(List<String> ids,
Map<String,EvaluatorDescriptor> evaluators)
Create AvroEvaluatorsInfo object.
|
AvroEvaluatorList |
AvroEvaluatorListSerializer.toAvro(Map<String,EvaluatorDescriptor> evaluatorMap,
int totalEvaluators,
String startTime)
Build AvroEvaluatorList object.
|
AvroEvaluatorList |
EvaluatorListSerializer.toAvro(Map<String,EvaluatorDescriptor> evaluatorMap,
int totalEvaluators,
String startTime)
Build AvroEvaluatorList object
|
Copyright © 2015 The Apache Software Foundation. All rights reserved.