| Package | Description |
|---|---|
| org.apache.reef.driver |
Driver APIs for REEF in terms of Rx.
|
| org.apache.reef.driver.evaluator |
Evaluator-related utilities.
|
| org.apache.reef.io.data.loading.api |
Data Loading Service API.
|
| org.apache.reef.io.data.loading.impl |
Implementations of Data Loading Service.
|
| 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)
Get a new builder from the existing request.
|
void |
EvaluatorRequestor.submit(EvaluatorRequest req)
Submit the request for new evaluator.
|
| Modifier and Type | Method and Description |
|---|---|
DataLoadingRequestBuilder |
DataLoadingRequestBuilder.addComputeRequest(EvaluatorRequest computeRequest)
Adds a single request to the compute requests list.
|
DataLoadingRequestBuilder |
DataLoadingRequestBuilder.addDataRequest(EvaluatorRequest dataRequest)
Adds a single request to the data requests list.
|
void |
ResourceRequestHandler.onNext(EvaluatorRequest request) |
| Modifier and Type | Method and Description |
|---|---|
DataLoadingRequestBuilder |
DataLoadingRequestBuilder.addComputeRequests(List<EvaluatorRequest> computeRequests)
Adds the requests to the compute requests list.
|
DataLoadingRequestBuilder |
DataLoadingRequestBuilder.addDataRequests(List<EvaluatorRequest> dataRequests)
Adds the requests to the data requests list.
|
| Modifier and Type | Method and Description |
|---|---|
static EvaluatorRequest |
AvroEvaluatorRequestSerializer.fromString(String serializedRequest)
Deserialize EvaluatorRequest.
|
| Modifier and Type | Method and Description |
|---|---|
static String |
AvroEvaluatorRequestSerializer.toString(EvaluatorRequest request)
Serialize EvaluatorRequest.
|
| Modifier and Type | Method and Description |
|---|---|
void |
EvaluatorRequestorImpl.submit(EvaluatorRequest req) |
Copyright © 2017 The Apache Software Foundation. All rights reserved.