| Package | Description | 
|---|---|
| org.apache.reef.proto | |
| org.apache.reef.runtime.common.driver.evaluator | 
 Driver-Side representations of Evaluators. 
 | 
| org.apache.reef.runtime.common.driver.resourcemanager | 
 Classes that interface with the resourcemanager (Local, YARN, ...) in the Driver. 
 | 
| org.apache.reef.runtime.local.process | 
 Infrastructure for managing processes. 
 | 
| Modifier and Type | Field and Description | 
|---|---|
static com.google.protobuf.Parser<DriverRuntimeProtocol.ResourceStatusProto> | 
DriverRuntimeProtocol.ResourceStatusProto.PARSER  | 
| Modifier and Type | Method and Description | 
|---|---|
DriverRuntimeProtocol.ResourceStatusProto | 
DriverRuntimeProtocol.ResourceStatusProto.Builder.build()  | 
DriverRuntimeProtocol.ResourceStatusProto | 
DriverRuntimeProtocol.ResourceStatusProto.Builder.buildPartial()  | 
static DriverRuntimeProtocol.ResourceStatusProto | 
DriverRuntimeProtocol.ResourceStatusProto.getDefaultInstance()  | 
DriverRuntimeProtocol.ResourceStatusProto | 
DriverRuntimeProtocol.ResourceStatusProto.getDefaultInstanceForType()  | 
DriverRuntimeProtocol.ResourceStatusProto | 
DriverRuntimeProtocol.ResourceStatusProto.Builder.getDefaultInstanceForType()  | 
static DriverRuntimeProtocol.ResourceStatusProto | 
DriverRuntimeProtocol.ResourceStatusProto.parseDelimitedFrom(InputStream input)  | 
static DriverRuntimeProtocol.ResourceStatusProto | 
DriverRuntimeProtocol.ResourceStatusProto.parseDelimitedFrom(InputStream input,
                                    com.google.protobuf.ExtensionRegistryLite extensionRegistry)  | 
static DriverRuntimeProtocol.ResourceStatusProto | 
DriverRuntimeProtocol.ResourceStatusProto.parseFrom(byte[] data)  | 
static DriverRuntimeProtocol.ResourceStatusProto | 
DriverRuntimeProtocol.ResourceStatusProto.parseFrom(byte[] data,
                  com.google.protobuf.ExtensionRegistryLite extensionRegistry)  | 
static DriverRuntimeProtocol.ResourceStatusProto | 
DriverRuntimeProtocol.ResourceStatusProto.parseFrom(com.google.protobuf.ByteString data)  | 
static DriverRuntimeProtocol.ResourceStatusProto | 
DriverRuntimeProtocol.ResourceStatusProto.parseFrom(com.google.protobuf.ByteString data,
                  com.google.protobuf.ExtensionRegistryLite extensionRegistry)  | 
static DriverRuntimeProtocol.ResourceStatusProto | 
DriverRuntimeProtocol.ResourceStatusProto.parseFrom(com.google.protobuf.CodedInputStream input)  | 
static DriverRuntimeProtocol.ResourceStatusProto | 
DriverRuntimeProtocol.ResourceStatusProto.parseFrom(com.google.protobuf.CodedInputStream input,
                  com.google.protobuf.ExtensionRegistryLite extensionRegistry)  | 
static DriverRuntimeProtocol.ResourceStatusProto | 
DriverRuntimeProtocol.ResourceStatusProto.parseFrom(InputStream input)  | 
static DriverRuntimeProtocol.ResourceStatusProto | 
DriverRuntimeProtocol.ResourceStatusProto.parseFrom(InputStream input,
                  com.google.protobuf.ExtensionRegistryLite extensionRegistry)  | 
| Modifier and Type | Method and Description | 
|---|---|
com.google.protobuf.Parser<DriverRuntimeProtocol.ResourceStatusProto> | 
DriverRuntimeProtocol.ResourceStatusProto.getParserForType()  | 
| Modifier and Type | Method and Description | 
|---|---|
DriverRuntimeProtocol.ResourceStatusProto.Builder | 
DriverRuntimeProtocol.ResourceStatusProto.Builder.mergeFrom(DriverRuntimeProtocol.ResourceStatusProto other)  | 
static DriverRuntimeProtocol.ResourceStatusProto.Builder | 
DriverRuntimeProtocol.ResourceStatusProto.newBuilder(DriverRuntimeProtocol.ResourceStatusProto prototype)  | 
| Modifier and Type | Method and Description | 
|---|---|
EvaluatorManager | 
EvaluatorManagerFactory.createForEvaluatorFailedDuringDriverRestart(DriverRuntimeProtocol.ResourceStatusProto resourceStatusProto)  | 
void | 
EvaluatorManager.onResourceStatusMessage(DriverRuntimeProtocol.ResourceStatusProto resourceStatusProto)
Resource status information from the (actual) resource manager. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ResourceStatusHandler.onNext(DriverRuntimeProtocol.ResourceStatusProto resourceStatusProto)
This resource status message comes from the ResourceManager layer; telling me what it thinks
 about the state of the resource executing an Evaluator; This method simply passes the message
 off to the referenced EvaluatorManager 
 | 
| Constructor and Description | 
|---|
ReefRunnableProcessObserver(EventHandler<DriverRuntimeProtocol.ResourceStatusProto> resourceStatusHandler,
                                                      InjectionFuture<ResourceManager> resourceManager)  | 
Copyright © 2015 The Apache Software Foundation. All rights reserved.