Package | Description |
---|---|
org.apache.reef.client |
Client APIs for REEF.
|
org.apache.reef.examples.data.loading |
A line counter example using data loading service.
|
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.runtime.common.client |
Implementation of the client-side REEF API.
|
org.apache.reef.runtime.common.client.defaults |
Default implementations for the optional client-side event handlers.
|
org.apache.reef.runtime.common.client.parameters |
Parameters used by client.
|
org.apache.reef.runtime.common.driver |
Implementation of the Driver-side REEF APIs.
|
org.apache.reef.runtime.common.files |
This package will contain the implementation of the REEF file system standard.
|
org.apache.reef.runtime.common.launch |
Common launch code between Driver and Evaluator.
|
org.apache.reef.runtime.hdinsight.client |
The client to submit jobs to HDInsight.
|
org.apache.reef.runtime.mesos.client |
Client-side event handlers for Mesos resourcemanager.
|
org.apache.reef.runtime.yarn.client |
Client-side event handlers for YARN resourcemanager.
|
org.apache.reef.runtime.yarn.driver |
The Driver-Side implementation of the YARN adapter for REEF.
|
org.apache.reef.tests |
Tests for REEF implementations.
|
org.apache.reef.vortex.api |
Vortex user api for running jobs on Vortex.
|
Modifier and Type | Interface and Description |
---|---|
interface |
CompletedJob
Represents a completed REEF job.
|
class |
DriverConfiguration
A ConfigurationModule for Drivers.
|
class |
DriverLauncher
A launcher for REEF Drivers.
|
class |
DriverRestartConfiguration
EventHandlers specific to Driver Restart.
|
class |
DriverServiceConfiguration
Use this ConfigurationModule to configure Services to be run in the Driver.
|
class |
FailedJob
An error message that REEF Client receives when there is a user error in REEF job.
|
class |
JobMessage
A message received by the client from the driver.
|
interface |
REEF
The main entry point into the REEF resourcemanager.
|
interface |
RunningJob
Represents a running REEF job.
|
Modifier and Type | Class and Description |
---|---|
class |
DataLoadingREEF
Client for the data loading demo app.
|
Modifier and Type | Class and Description |
---|---|
class |
OutputServiceREEF
Client for the output service demo app.
|
Modifier and Type | Class and Description |
---|---|
class |
BroadcastREEF
Client for broadcast example.
|
Modifier and Type | Class and Description |
---|---|
class |
REEFImplementation
Default REEF implementation.
|
class |
RunningJobImpl
Implementation of RunningJob.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultCompletedJobHandler
Default event handler for CompletedJob: Logging it.
|
class |
DefaultFailedJobHandler
Default event handler for FailedJob: rethrow the exception.
|
class |
DefaultJobMessageHandler
Default event handler for job message: Logging it.
|
class |
DefaultRunningJobHandler
Default event handler for RunningJob: Logging it.
|
class |
DefaultRuntimeErrorHandler
Default event handler for REEF FailedRuntime: rethrow the exception.
|
Modifier and Type | Class and Description |
---|---|
class |
ClientPresent
A Tang named parameter that indicates whether or not a client (handler for the various Job events) is present.
|
Modifier and Type | Class and Description |
---|---|
class |
DriverRuntimeConfiguration
ConfigurationModule for driver runtime.
|
class |
DriverRuntimeRestartConfiguration
The base configuration module for driver restart configurations of all runtimes.
|
Modifier and Type | Class and Description |
---|---|
class |
JobJarMaker
Utility that takes a JobSubmissionProto and turns it into a Job Submission Jar.
|
Modifier and Type | Class and Description |
---|---|
class |
REEFMessageCodec
Codec for REEF's control flow messages.
|
Modifier and Type | Class and Description |
---|---|
class |
HDInsightDriverConfiguration
ConfigurationModule to create a Driver configuration.
|
class |
HDInsightJobSubmissionHandler
Handles job submission to a HDInsight instance.
|
Modifier and Type | Class and Description |
---|---|
class |
MesosClientConfiguration
A ConfigurationModule for the Mesos resource manager.
|
Modifier and Type | Class and Description |
---|---|
class |
YarnClientConfiguration
A ConfigurationModule for the YARN resourcemanager.
|
class |
YarnDriverConfiguration
Additional YARN-Specific configuration options to be merged with DriverConfiguration.
|
Modifier and Type | Class and Description |
---|---|
class |
YarnDriverRestartConfiguration
Use this ConfigurationModule to configure YARN-specific Restart options for the driver.
|
Modifier and Type | Class and Description |
---|---|
class |
TestDriverLauncher
A launcher for REEF Drivers.
|
Modifier and Type | Class and Description |
---|---|
class |
AggregateResult<TInput,TOutput>
The result of an aggregate.
|
class |
AggregateResultSynchronous<TInput,TOutput>
The synchronous result of an aggregate, returned by
VortexAggregateFuture.get() . |
interface |
VortexAggregateFunction<TOutput>
Typed user function for Local Aggregation.
|
class |
VortexAggregateFuture<TInput,TOutput>
The interface between user code and aggregation Tasklets.
|
class |
VortexAggregatePolicy
The policy for local aggregation on the
VortexWorker s. |
Copyright © 2016 The Apache Software Foundation. All rights reserved.