| Package | Description |
|---|---|
| org.apache.reef.driver |
Driver APIs for REEF in terms of Rx.
|
| org.apache.reef.driver.evaluator | |
| org.apache.reef.io.data.loading.api | |
| org.apache.reef.io.data.loading.impl | |
| org.apache.reef.runtime.common.driver |
Implementation of the Driver-side REEF APIs.
|
| Modifier and Type | Method and Description |
|---|---|
Set<EvaluatorRequest> |
FlexiblePreemptionEvent.getEvaluatorRequest() |
| Modifier and Type | Method and Description |
|---|---|
EvaluatorRequest |
EvaluatorRequest.Builder.build()
Builds the
EvaluatorRequest. |
| Modifier and Type | Method and Description |
|---|---|
static EvaluatorRequest.Builder |
EvaluatorRequest.newBuilder(EvaluatorRequest request) |
void |
EvaluatorRequestor.submit(EvaluatorRequest req)
Submit the request for new evaluator.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ResourceRequestHandler.onNext(EvaluatorRequest request) |
DataLoadingRequestBuilder |
DataLoadingRequestBuilder.setComputeRequest(EvaluatorRequest computeRequest) |
| Modifier and Type | Method and Description |
|---|---|
static EvaluatorRequest |
EvaluatorRequestSerializer.deserialize(String serializedRequest) |
| Modifier and Type | Method and Description |
|---|---|
static String |
EvaluatorRequestSerializer.serialize(EvaluatorRequest request) |
| Modifier and Type | Method and Description |
|---|---|
void |
EvaluatorRequestorImpl.submit(EvaluatorRequest req) |
Copyright © 2015 The Apache Software Foundation. All rights reserved.