Package | Description |
---|---|
org.apache.reef.driver.context |
Driver Contexts and their configurations.
|
org.apache.reef.driver.evaluator |
Evaluator-related utilities.
|
org.apache.reef.io.watcher.util |
Utility classes for Watcher.
|
org.apache.reef.javabridge |
The Java-side of the CLR/Java bridge.
|
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 |
HTTP Server component to implement a REST API for the Driver or Evaluators.
|
Modifier and Type | Method and Description |
---|---|
EvaluatorDescriptor |
ContextBase.getEvaluatorDescriptor() |
Modifier and Type | Method and Description |
---|---|
EvaluatorDescriptor |
AllocatedEvaluator.getEvaluatorDescriptor() |
Modifier and Type | Method and Description |
---|---|
static AvroEvaluatorDescriptor |
WatcherAvroUtil.toAvroEvaluatorDescriptor(EvaluatorDescriptor evaluatorDescriptor) |
Modifier and Type | Method and Description |
---|---|
EvaluatorDescriptor |
FailedContextBridge.getEvaluatorDescriptor() |
EvaluatorDescriptor |
ClosedContextBridge.getEvaluatorDescriptor() |
Modifier and Type | Method and Description |
---|---|
static String |
Utilities.getEvaluatorDescriptorString(EvaluatorDescriptor evaluatorDescriptor) |
Modifier and Type | Method and Description |
---|---|
EvaluatorDescriptor |
FailedContextImpl.getEvaluatorDescriptor() |
EvaluatorDescriptor |
EvaluatorContext.getEvaluatorDescriptor() |
EvaluatorDescriptor |
ClosedContextImpl.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() |
EvaluatorDescriptor |
AllocatedEvaluatorImpl.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 |
EvaluatorListSerializer.toAvro(Map<String,EvaluatorDescriptor> evaluatorMap,
int totalEvaluators,
String startTime)
Build AvroEvaluatorList object.
|
AvroEvaluatorList |
AvroEvaluatorListSerializer.toAvro(Map<String,EvaluatorDescriptor> evaluatorMap,
int totalEvaluators,
String startTime)
Build AvroEvaluatorList object.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.