| Package | Description | 
|---|---|
| org.apache.reef.proto | |
| org.apache.reef.runtime.common.driver.task | 
 Driver-Side representations of tasks. 
 | 
| 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. 
 | 
| org.apache.reef.runtime.common.evaluator.task | 
 Task-related implementation of the Evaluator resourcemanager. 
 | 
| Modifier and Type | Field and Description | 
|---|---|
static com.google.protobuf.Parser<ReefServiceProtos.TaskStatusProto> | 
ReefServiceProtos.TaskStatusProto.PARSER  | 
| Modifier and Type | Method and Description | 
|---|---|
ReefServiceProtos.TaskStatusProto | 
ReefServiceProtos.TaskStatusProto.Builder.build()  | 
ReefServiceProtos.TaskStatusProto | 
ReefServiceProtos.TaskStatusProto.Builder.buildPartial()  | 
static ReefServiceProtos.TaskStatusProto | 
ReefServiceProtos.TaskStatusProto.getDefaultInstance()  | 
ReefServiceProtos.TaskStatusProto | 
ReefServiceProtos.TaskStatusProto.getDefaultInstanceForType()  | 
ReefServiceProtos.TaskStatusProto | 
ReefServiceProtos.TaskStatusProto.Builder.getDefaultInstanceForType()  | 
ReefServiceProtos.TaskStatusProto | 
EvaluatorRuntimeProtocol.EvaluatorHeartbeatProtoOrBuilder.getTaskStatus()
optional .TaskStatusProto task_status = 4; | 
ReefServiceProtos.TaskStatusProto | 
EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.getTaskStatus()
optional .TaskStatusProto task_status = 4; | 
ReefServiceProtos.TaskStatusProto | 
EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder.getTaskStatus()
optional .TaskStatusProto task_status = 4; | 
static ReefServiceProtos.TaskStatusProto | 
ReefServiceProtos.TaskStatusProto.parseDelimitedFrom(InputStream input)  | 
static ReefServiceProtos.TaskStatusProto | 
ReefServiceProtos.TaskStatusProto.parseDelimitedFrom(InputStream input,
                                    com.google.protobuf.ExtensionRegistryLite extensionRegistry)  | 
static ReefServiceProtos.TaskStatusProto | 
ReefServiceProtos.TaskStatusProto.parseFrom(byte[] data)  | 
static ReefServiceProtos.TaskStatusProto | 
ReefServiceProtos.TaskStatusProto.parseFrom(byte[] data,
                  com.google.protobuf.ExtensionRegistryLite extensionRegistry)  | 
static ReefServiceProtos.TaskStatusProto | 
ReefServiceProtos.TaskStatusProto.parseFrom(com.google.protobuf.ByteString data)  | 
static ReefServiceProtos.TaskStatusProto | 
ReefServiceProtos.TaskStatusProto.parseFrom(com.google.protobuf.ByteString data,
                  com.google.protobuf.ExtensionRegistryLite extensionRegistry)  | 
static ReefServiceProtos.TaskStatusProto | 
ReefServiceProtos.TaskStatusProto.parseFrom(com.google.protobuf.CodedInputStream input)  | 
static ReefServiceProtos.TaskStatusProto | 
ReefServiceProtos.TaskStatusProto.parseFrom(com.google.protobuf.CodedInputStream input,
                  com.google.protobuf.ExtensionRegistryLite extensionRegistry)  | 
static ReefServiceProtos.TaskStatusProto | 
ReefServiceProtos.TaskStatusProto.parseFrom(InputStream input)  | 
static ReefServiceProtos.TaskStatusProto | 
ReefServiceProtos.TaskStatusProto.parseFrom(InputStream input,
                  com.google.protobuf.ExtensionRegistryLite extensionRegistry)  | 
| Modifier and Type | Method and Description | 
|---|---|
com.google.protobuf.Parser<ReefServiceProtos.TaskStatusProto> | 
ReefServiceProtos.TaskStatusProto.getParserForType()  | 
| Modifier and Type | Method and Description | 
|---|---|
ReefServiceProtos.TaskStatusProto.Builder | 
ReefServiceProtos.TaskStatusProto.Builder.mergeFrom(ReefServiceProtos.TaskStatusProto other)  | 
EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder | 
EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder.mergeTaskStatus(ReefServiceProtos.TaskStatusProto value)
optional .TaskStatusProto task_status = 4; | 
static ReefServiceProtos.TaskStatusProto.Builder | 
ReefServiceProtos.TaskStatusProto.newBuilder(ReefServiceProtos.TaskStatusProto prototype)  | 
EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder | 
EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder.setTaskStatus(ReefServiceProtos.TaskStatusProto value)
optional .TaskStatusProto task_status = 4; | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
TaskRepresenter.onTaskStatusMessage(ReefServiceProtos.TaskStatusProto taskStatusProto)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
HeartBeatManager.sendTaskStatus(ReefServiceProtos.TaskStatusProto taskStatusProto)
Called with a specific TaskStatus that must be delivered to the driver. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Optional<ReefServiceProtos.TaskStatusProto> | 
ContextManager.getTaskStatus()  | 
| Modifier and Type | Method and Description | 
|---|---|
ReefServiceProtos.TaskStatusProto | 
TaskRuntime.getStatusProto()
Called by heartbeat manager 
 | 
Copyright © 2015 The Apache Software Foundation. All rights reserved.