Package | Description |
---|---|
org.apache.reef.examples.data.output |
Example application using the output service.
|
org.apache.reef.examples.group.broadcast |
Broadcast Group Communication example.
|
org.apache.reef.examples.helloCLR |
The Hello REEF example for the CLR.
|
org.apache.reef.examples.hellohttp |
Distributed shell example based on REEF HTTP Server component.
|
org.apache.reef.io.data.loading.api |
Data Loading Service API.
|
org.apache.reef.javabridge |
The Java-side of the CLR/Java bridge.
|
org.apache.reef.runtime.common.driver |
Implementation of the Driver-side REEF APIs.
|
org.apache.reef.tests.fail.driver |
Tests for Driver-side failures.
|
org.apache.reef.tests.fail.task |
Tests for Tasks fail in various cases.
|
org.apache.reef.tests.yarn.failure |
Tests for YARN failures.
|
Constructor and Description |
---|
OutputServiceDriver(EvaluatorRequestor requestor,
OutputService outputService)
Job driver constructor - instantiated via TANG.
|
Constructor and Description |
---|
BroadcastDriver(EvaluatorRequestor requestor,
GroupCommDriver groupCommDriver,
ConfigurationSerializer confSerializer,
int dimensions,
int numberOfReceivers) |
Constructor and Description |
---|
HelloDriver(EvaluatorRequestor requestor,
CLRProcessFactory clrProcessFactory)
Job driver constructor - instantiated via TANG.
|
Constructor and Description |
---|
HttpShellJobDriver(EvaluatorRequestor requestor,
org.apache.reef.examples.hellohttp.HttpServerShellCmdHandler.ClientCallBackHandler clientCallBackHandler)
Job Driver Constructor.
|
Constructor and Description |
---|
DataLoader(Clock clock,
EvaluatorRequestor requestor,
DataLoadingService dataLoadingService,
Set<String> serializedComputeRequests,
Set<String> serializedDataRequests)
Allows to specify compute and data evaluator requests in particular
locations.
|
ResourceRequestHandler(EvaluatorRequestor requestor) |
Constructor and Description |
---|
EvaluatorRequestorBridge(EvaluatorRequestor evaluatorRequestor,
boolean isBlocked,
LoggingScopeFactory loggingScopeFactory) |
FailedEvaluatorBridge(FailedEvaluator failedEvaluator,
EvaluatorRequestor evaluatorRequestor,
boolean blockedForAdditionalEvaluator,
LoggingScopeFactory loggingScopeFactory) |
Modifier and Type | Class and Description |
---|---|
class |
EvaluatorRequestorImpl
Implementation of the EvaluatorRequestor that translates the request and hands it down to the underlying RM.
|
Constructor and Description |
---|
DriverFailOnFail(JobMessageObserver client,
EvaluatorRequestor requestor) |
FailDriver(String failMsgClassName,
EvaluatorRequestor requestor,
Clock clock) |
FailDriverDelayedMsg(EvaluatorRequestor requestor,
Clock clock) |
Constructor and Description |
---|
Driver(String failTaskName,
EvaluatorRequestor requestor) |
Constructor and Description |
---|
FailureDriver(EvaluatorRequestor requestor) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.