Package | Description |
---|---|
org.apache.reef.proto | |
org.apache.reef.runtime.common |
REEF implementation.
|
org.apache.reef.runtime.common.client |
Implementation of the client-side REEF API.
|
org.apache.reef.runtime.common.driver.client |
Objects representing the Client on the Driver.
|
org.apache.reef.tests.fail.driver |
Tests for Driver-side failures.
|
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<ReefServiceProtos.JobStatusProto> |
ReefServiceProtos.JobStatusProto.PARSER |
Modifier and Type | Method and Description |
---|---|
ReefServiceProtos.JobStatusProto |
ReefServiceProtos.JobStatusProto.Builder.build() |
ReefServiceProtos.JobStatusProto |
ReefServiceProtos.JobStatusProto.Builder.buildPartial() |
static ReefServiceProtos.JobStatusProto |
ReefServiceProtos.JobStatusProto.getDefaultInstance() |
ReefServiceProtos.JobStatusProto |
ReefServiceProtos.JobStatusProto.getDefaultInstanceForType() |
ReefServiceProtos.JobStatusProto |
ReefServiceProtos.JobStatusProto.Builder.getDefaultInstanceForType() |
ReefServiceProtos.JobStatusProto |
REEFProtocol.REEFMessageOrBuilder.getJobStatus()
optional .JobStatusProto jobStatus = 4; |
ReefServiceProtos.JobStatusProto |
REEFProtocol.REEFMessage.getJobStatus()
optional .JobStatusProto jobStatus = 4; |
ReefServiceProtos.JobStatusProto |
REEFProtocol.REEFMessage.Builder.getJobStatus()
optional .JobStatusProto jobStatus = 4; |
static ReefServiceProtos.JobStatusProto |
ReefServiceProtos.JobStatusProto.parseDelimitedFrom(InputStream input) |
static ReefServiceProtos.JobStatusProto |
ReefServiceProtos.JobStatusProto.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static ReefServiceProtos.JobStatusProto |
ReefServiceProtos.JobStatusProto.parseFrom(byte[] data) |
static ReefServiceProtos.JobStatusProto |
ReefServiceProtos.JobStatusProto.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static ReefServiceProtos.JobStatusProto |
ReefServiceProtos.JobStatusProto.parseFrom(com.google.protobuf.ByteString data) |
static ReefServiceProtos.JobStatusProto |
ReefServiceProtos.JobStatusProto.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static ReefServiceProtos.JobStatusProto |
ReefServiceProtos.JobStatusProto.parseFrom(com.google.protobuf.CodedInputStream input) |
static ReefServiceProtos.JobStatusProto |
ReefServiceProtos.JobStatusProto.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static ReefServiceProtos.JobStatusProto |
ReefServiceProtos.JobStatusProto.parseFrom(InputStream input) |
static ReefServiceProtos.JobStatusProto |
ReefServiceProtos.JobStatusProto.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<ReefServiceProtos.JobStatusProto> |
ReefServiceProtos.JobStatusProto.getParserForType() |
Modifier and Type | Method and Description |
---|---|
ReefServiceProtos.JobStatusProto.Builder |
ReefServiceProtos.JobStatusProto.Builder.mergeFrom(ReefServiceProtos.JobStatusProto other) |
REEFProtocol.REEFMessage.Builder |
REEFProtocol.REEFMessage.Builder.mergeJobStatus(ReefServiceProtos.JobStatusProto value)
optional .JobStatusProto jobStatus = 4; |
static ReefServiceProtos.JobStatusProto.Builder |
ReefServiceProtos.JobStatusProto.newBuilder(ReefServiceProtos.JobStatusProto prototype) |
REEFProtocol.REEFMessage.Builder |
REEFProtocol.REEFMessage.Builder.setJobStatus(ReefServiceProtos.JobStatusProto value)
optional .JobStatusProto jobStatus = 4; |
Modifier and Type | Method and Description |
---|---|
ReefServiceProtos.JobStatusProto |
REEFEnvironment.getLastStatus()
Get the last known status of REEF job.
|
Modifier and Type | Method and Description |
---|---|
void |
RunningJobImpl.onNext(ReefServiceProtos.JobStatusProto value) |
Modifier and Type | Method and Description |
---|---|
ReefServiceProtos.JobStatusProto |
LoggingJobStatusHandler.getLastStatus()
Return the last known status of the REEF job.
|
ReefServiceProtos.JobStatusProto |
JobStatusHandler.getLastStatus()
Return the last known status of the REEF job.
|
Modifier and Type | Method and Description |
---|---|
void |
LoggingJobStatusHandler.onNext(ReefServiceProtos.JobStatusProto jobStatusProto) |
void |
ClientConnection.send(ReefServiceProtos.JobStatusProto status)
Send the given JobStatus to the client.
|
Modifier and Type | Method and Description |
---|---|
static ReefServiceProtos.JobStatusProto |
FailClient.runInProcess(Class<?> failMsgClass,
Configuration runtimeConfig,
int timeOut)
Run REEF in-process using specified runtime and fail (raise an exception) in a specified class.
|
Copyright © 2017 The Apache Software Foundation. All rights reserved.