| Package | Description |
|---|---|
| org.apache.reef.client |
Client APIs for REEF.
|
| org.apache.reef.driver.context | |
| org.apache.reef.driver.task | |
| org.apache.reef.io.checkpoint.fs | |
| org.apache.reef.io.network.naming |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
| org.apache.reef.poison |
Fault injection for REEF.
|
| org.apache.reef.runtime.common.evaluator |
Evaluator-side implementation of the REEF API.
|
| org.apache.reef.runtime.hdinsight.client |
The client to submit jobs to HDInsight.
|
| org.apache.reef.runtime.local.client |
client-side event handlers for the local resourcemanager
|
| org.apache.reef.runtime.local.driver |
The resource manager for the local resourcemanager
|
| org.apache.reef.runtime.yarn.client | |
| org.apache.reef.runtime.yarn.driver |
The Driver-Side implementation of the YARN adapter for REEF.
|
| org.apache.reef.tang.examples.timer |
A more complicated version of the Timer example, including delegating
interfaces to default implementations.
|
| org.apache.reef.util |
Various utility classes.
|
| org.apache.reef.webserver |
| Modifier and Type | Field and Description |
|---|---|
static OptionalParameter<String> |
DriverConfiguration.DRIVER_IDENTIFIER
Identifies the driver and therefore the JOB.
|
static OptionalParameter<String> |
DriverConfiguration.DRIVER_JOB_SUBMISSION_DIRECTORY
Job submission directory to be used by driver.
|
static OptionalParameter<Integer> |
DriverConfiguration.DRIVER_MEMORY
The amount of memory to be allocated for the Driver.
|
static OptionalParameter<Integer> |
DriverConfiguration.EVALUATOR_DISPATCHER_THREADS
"Number of threads allocated per evaluator to dispatch events from this Evaluator.
|
static OptionalParameter<String> |
DriverServiceConfiguration.GLOBAL_FILES
Files to be made available on the Driver and all Evaluators.
|
static OptionalParameter<String> |
DriverConfiguration.GLOBAL_FILES
Files to be made available on the Driver and all Evaluators.
|
static OptionalParameter<String> |
DriverServiceConfiguration.GLOBAL_LIBRARIES
Libraries to be made available on the Driver and all Evaluators.
|
static OptionalParameter<String> |
DriverConfiguration.GLOBAL_LIBRARIES
Libraries to be made available on the Driver and all Evaluators.
|
static OptionalParameter<String> |
DriverServiceConfiguration.LOCAL_FILES
Files to be made available on the Driver only.
|
static OptionalParameter<String> |
DriverConfiguration.LOCAL_FILES
Files to be made available on the Driver only.
|
static OptionalParameter<String> |
DriverServiceConfiguration.LOCAL_LIBRARIES
Libraries to be made available on the Driver only.
|
static OptionalParameter<String> |
DriverConfiguration.LOCAL_LIBRARIES
Libraries to be made available on the Driver only.
|
| Modifier and Type | Field and Description |
|---|---|
static OptionalParameter<Object> |
ServiceConfiguration.SERVICES
A set of services to instantiate.
|
| Modifier and Type | Field and Description |
|---|---|
static OptionalParameter<String> |
TaskConfiguration.MEMENTO
The Base64 encoded memento to be passed to Task.call().
|
| Modifier and Type | Field and Description |
|---|---|
static OptionalParameter<String> |
FSCheckPointServiceConfiguration.PREFIX
Prefix for checkpoint files (optional).
|
static OptionalParameter<Short> |
FSCheckPointServiceConfiguration.REPLICATION_FACTOR
Replication factor to be used for the checkpoints.
|
| Modifier and Type | Field and Description |
|---|---|
static OptionalParameter<String> |
NameServerConfiguration.NAME_SERVER_HOSTNAME
DNS hostname running the name service
|
static OptionalParameter<IdentifierFactory> |
NameServerConfiguration.NAME_SERVER_IDENTIFIER_FACTORY
Identifier factory for the name service
|
static OptionalParameter<Integer> |
NameServerConfiguration.NAME_SERVICE_PORT
The port used by name server
|
| Modifier and Type | Field and Description |
|---|---|
static OptionalParameter<Double> |
PoisonedConfiguration.CRASH_PROBABILITY
The probability with which a crash is to occur.
|
static OptionalParameter<Integer> |
PoisonedConfiguration.CRASH_TIMEOUT
The time window in seconds beginning at ContextStart during which the crash is to occur.
|
| Modifier and Type | Field and Description |
|---|---|
static OptionalParameter<String> |
EvaluatorConfiguration.APPLICATION_IDENTIFIER |
static OptionalParameter<Integer> |
EvaluatorConfiguration.HEARTBEAT_PERIOD |
static OptionalParameter<String> |
EvaluatorConfiguration.ROOT_SERVICE_CONFIGURATION |
static OptionalParameter<String> |
EvaluatorConfiguration.TASK_CONFIGURATION |
| Modifier and Type | Field and Description |
|---|---|
static OptionalParameter<Long> |
HDInsightDriverConfiguration.EVALUATOR_TIMEOUT |
static OptionalParameter<Double> |
HDInsightDriverConfiguration.JVM_HEAP_SLACK
The fraction of the container memory NOT to use for the Java Heap.
|
static OptionalParameter<Integer> |
HDInsightDriverConfiguration.YARN_HEARTBEAT_INTERVAL |
| Modifier and Type | Field and Description |
|---|---|
static OptionalParameter<Double> |
LocalRuntimeConfiguration.JVM_HEAP_SLACK
The fraction of the container memory NOT to use for the Java Heap.
|
static OptionalParameter<Integer> |
LocalRuntimeConfiguration.NUMBER_OF_THREADS
The number of threads or processes available to the resourcemanager.
|
static OptionalParameter<String> |
LocalRuntimeConfiguration.RUNTIME_ROOT_FOLDER
The folder in which the sub-folders, one per Node, will be created.
|
| Modifier and Type | Field and Description |
|---|---|
static OptionalParameter<String> |
LocalDriverConfiguration.GLOBAL_FILES
Files for the driver and all evaluators.
|
static OptionalParameter<String> |
LocalDriverConfiguration.GLOBAL_LIBRARIES
Libraries for the driver and all evaluators.
|
static OptionalParameter<Double> |
LocalDriverConfiguration.JVM_HEAP_SLACK
The fraction of the container memory NOT to use for the Java Heap.
|
static OptionalParameter<String> |
LocalDriverConfiguration.LOCAL_FILES
Files for the driver only.
|
static OptionalParameter<String> |
LocalDriverConfiguration.LOCAL_LIBRARIES
Libraries for the driver only.
|
| Modifier and Type | Field and Description |
|---|---|
static OptionalParameter<Double> |
YarnClientConfiguration.JVM_HEAP_SLACK |
static OptionalParameter<Integer> |
YarnClientConfiguration.YARN_PRIORITY |
static OptionalParameter<String> |
YarnClientConfiguration.YARN_QUEUE_NAME |
| Modifier and Type | Field and Description |
|---|---|
static OptionalParameter<String> |
YarnDriverConfiguration.CLIENT_REMOTE_IDENTIFIER
The client remote identifier.
|
static OptionalParameter<Long> |
YarnDriverConfiguration.EVALUATOR_TIMEOUT |
static OptionalParameter<Double> |
YarnDriverConfiguration.JVM_HEAP_SLACK
The fraction of the container memory NOT to use for the Java Heap.
|
static OptionalParameter<Integer> |
YarnDriverConfiguration.YARN_HEARTBEAT_INTERVAL |
| Modifier and Type | Field and Description |
|---|---|
static OptionalParameter<Integer> |
TimerMock.TimerMockConf.MOCK_SLEEP_TIME |
| Modifier and Type | Method and Description |
|---|---|
static ConfigurationModule |
EnvironmentUtils.addClasspath(ConfigurationModule config,
OptionalParameter<String> param)
Deprecated.
Using this method is inherently non-deterministic as it depends on environment variables on your local
machine.
|
| Modifier and Type | Field and Description |
|---|---|
static OptionalParameter<HttpHandler> |
HttpHandlerConfiguration.HTTP_HANDLERS
Specify optional parameter for HttpEventHandlers
|
Copyright © 2015 The Apache Software Foundation. All rights reserved.