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 © 2016 The Apache Software Foundation. All rights reserved.