| 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.