| Package | Description | 
|---|---|
| org.apache.reef.proto | |
| org.apache.reef.runtime.common.driver.context | 
 Implementations of Driver-Side representations of Contexts running on an Evaluator 
 | 
| org.apache.reef.runtime.common.evaluator | 
 Evaluator-side implementation of the REEF API. 
 | 
| org.apache.reef.runtime.common.evaluator.context | 
 Context implementation of the Evaluator resourcemanager. 
 | 
| Modifier and Type | Field and Description | 
|---|---|
static com.google.protobuf.Parser<ReefServiceProtos.ContextStatusProto> | 
ReefServiceProtos.ContextStatusProto.PARSER  | 
| Modifier and Type | Method and Description | 
|---|---|
ReefServiceProtos.ContextStatusProto | 
ReefServiceProtos.ContextStatusProto.Builder.build()  | 
ReefServiceProtos.ContextStatusProto | 
ReefServiceProtos.ContextStatusProto.Builder.buildPartial()  | 
ReefServiceProtos.ContextStatusProto | 
EvaluatorRuntimeProtocol.EvaluatorHeartbeatProtoOrBuilder.getContextStatus(int index)
repeated .ContextStatusProto context_status = 3; | 
ReefServiceProtos.ContextStatusProto | 
EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.getContextStatus(int index)
repeated .ContextStatusProto context_status = 3; | 
ReefServiceProtos.ContextStatusProto | 
EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder.getContextStatus(int index)
repeated .ContextStatusProto context_status = 3; | 
static ReefServiceProtos.ContextStatusProto | 
ReefServiceProtos.ContextStatusProto.getDefaultInstance()  | 
ReefServiceProtos.ContextStatusProto | 
ReefServiceProtos.ContextStatusProto.getDefaultInstanceForType()  | 
ReefServiceProtos.ContextStatusProto | 
ReefServiceProtos.ContextStatusProto.Builder.getDefaultInstanceForType()  | 
static ReefServiceProtos.ContextStatusProto | 
ReefServiceProtos.ContextStatusProto.parseDelimitedFrom(InputStream input)  | 
static ReefServiceProtos.ContextStatusProto | 
ReefServiceProtos.ContextStatusProto.parseDelimitedFrom(InputStream input,
                                    com.google.protobuf.ExtensionRegistryLite extensionRegistry)  | 
static ReefServiceProtos.ContextStatusProto | 
ReefServiceProtos.ContextStatusProto.parseFrom(byte[] data)  | 
static ReefServiceProtos.ContextStatusProto | 
ReefServiceProtos.ContextStatusProto.parseFrom(byte[] data,
                  com.google.protobuf.ExtensionRegistryLite extensionRegistry)  | 
static ReefServiceProtos.ContextStatusProto | 
ReefServiceProtos.ContextStatusProto.parseFrom(com.google.protobuf.ByteString data)  | 
static ReefServiceProtos.ContextStatusProto | 
ReefServiceProtos.ContextStatusProto.parseFrom(com.google.protobuf.ByteString data,
                  com.google.protobuf.ExtensionRegistryLite extensionRegistry)  | 
static ReefServiceProtos.ContextStatusProto | 
ReefServiceProtos.ContextStatusProto.parseFrom(com.google.protobuf.CodedInputStream input)  | 
static ReefServiceProtos.ContextStatusProto | 
ReefServiceProtos.ContextStatusProto.parseFrom(com.google.protobuf.CodedInputStream input,
                  com.google.protobuf.ExtensionRegistryLite extensionRegistry)  | 
static ReefServiceProtos.ContextStatusProto | 
ReefServiceProtos.ContextStatusProto.parseFrom(InputStream input)  | 
static ReefServiceProtos.ContextStatusProto | 
ReefServiceProtos.ContextStatusProto.parseFrom(InputStream input,
                  com.google.protobuf.ExtensionRegistryLite extensionRegistry)  | 
| Modifier and Type | Method and Description | 
|---|---|
List<ReefServiceProtos.ContextStatusProto> | 
EvaluatorRuntimeProtocol.EvaluatorHeartbeatProtoOrBuilder.getContextStatusList()
repeated .ContextStatusProto context_status = 3; | 
List<ReefServiceProtos.ContextStatusProto> | 
EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.getContextStatusList()
repeated .ContextStatusProto context_status = 3; | 
List<ReefServiceProtos.ContextStatusProto> | 
EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder.getContextStatusList()
repeated .ContextStatusProto context_status = 3; | 
com.google.protobuf.Parser<ReefServiceProtos.ContextStatusProto> | 
ReefServiceProtos.ContextStatusProto.getParserForType()  | 
| Modifier and Type | Method and Description | 
|---|---|
EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder | 
EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder.addContextStatus(int index,
                                ReefServiceProtos.ContextStatusProto value)
repeated .ContextStatusProto context_status = 3; | 
EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder | 
EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder.addContextStatus(ReefServiceProtos.ContextStatusProto value)
repeated .ContextStatusProto context_status = 3; | 
ReefServiceProtos.ContextStatusProto.Builder | 
ReefServiceProtos.ContextStatusProto.Builder.mergeFrom(ReefServiceProtos.ContextStatusProto other)  | 
static ReefServiceProtos.ContextStatusProto.Builder | 
ReefServiceProtos.ContextStatusProto.newBuilder(ReefServiceProtos.ContextStatusProto prototype)  | 
EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder | 
EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder.setContextStatus(int index,
                                ReefServiceProtos.ContextStatusProto value)
repeated .ContextStatusProto context_status = 3; | 
| Modifier and Type | Method and Description | 
|---|---|
EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder | 
EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder.addAllContextStatus(Iterable<? extends ReefServiceProtos.ContextStatusProto> values)
repeated .ContextStatusProto context_status = 3; | 
| Modifier and Type | Method and Description | 
|---|---|
FailedContext | 
EvaluatorContext.getFailedContext(ReefServiceProtos.ContextStatusProto contextStatusProto)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ContextRepresenters.onContextStatusMessages(Iterable<ReefServiceProtos.ContextStatusProto> contextStatusProtos,
                                              boolean notifyClientOnNewActiveContext)
Process heartbeats from the contexts on an Evaluator. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
HeartBeatManager.sendContextStatus(ReefServiceProtos.ContextStatusProto contextStatusProto)
Called with a specific TaskStatus that must be delivered to the driver. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Collection<ReefServiceProtos.ContextStatusProto> | 
ContextManager.getContextStatusCollection()  | 
Copyright © 2015 The Apache Software Foundation. All rights reserved.