| Modifier and Type | Class and Description | 
|---|---|
class  | 
JobCompletedHandler
Event handler for CompletedJob 
 | 
class  | 
JobFailedHandler
Client EventHandler triggered on remote job failure. 
 | 
class  | 
JobMessageHandler
Client EventHandler that gets messages from the Driver. 
 | 
class  | 
JobRunningHandler
Client EventHandler triggered when the REEF job is running. 
 | 
class  | 
ResourceManagerErrorHandler
Client EventHandler triggered on resource manager error. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
ContextConfiguration.DriverReconnect  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
ClientCloseHandlers
Handles close requests from the client. 
 | 
class  | 
ClientCloseWithMessageHandlers
Handles client close requests 
 | 
class  | 
ClientMessageHandlers
Handles message from the Client. 
 | 
class  | 
ContextActiveHandlers
Handler for ActiveContext 
 | 
class  | 
ContextClosedHandlers
Handler for ClosedContext. 
 | 
class  | 
ContextFailedHandlers
Handler for FailedContext 
 | 
class  | 
ContextMessageHandlers
Context message handler. 
 | 
class  | 
DriverIdentifier
Driver Identifier 
 | 
class  | 
DriverIdleSources
Sources considered when making an idleness decision. 
 | 
class  | 
DriverJobSubmissionDirectory
Job submission directory 
 | 
class  | 
DriverLocalFiles
Files to be made accessible on the Driver only. 
 | 
class  | 
DriverLocalLibraries
Libraries to be made accessible on the Driver only. 
 | 
class  | 
DriverMemory
Driver RAM allocation in MB 
 | 
class  | 
DriverRestartCompletedHandlers
Handler for event that all evaluators have checked back in after driver restart and that the restart is completed 
 | 
class  | 
DriverRestartContextActiveHandlers
Handler for ActiveContext during a driver restart 
 | 
class  | 
DriverRestartHandler
The StartTime event is routed to this EventHandler if there is a restart, instead of to DriverStartHandler. 
 | 
class  | 
DriverRestartTaskRunningHandlers
Handler for RunningTask events during a Driver restart. 
 | 
class  | 
DriverStartHandler
Called once the Driver is completely setup. 
 | 
class  | 
EvaluatorAllocatedHandlers
Called when an allocated evaluator is given to the client. 
 | 
class  | 
EvaluatorCompletedHandlers
Called when an exception occurs on a running evaluator. 
 | 
class  | 
EvaluatorDispatcherThreads
Number of threads allocated per evaluator to dispatch events from that Evaluator. 
 | 
class  | 
EvaluatorFailedHandlers
Called when an exception occurs on a running evaluator. 
 | 
class  | 
JobGlobalFiles
Files to be made accessible on the Driver and all Evaluators. 
 | 
class  | 
JobGlobalLibraries
Libraries to be made accessible on the Driver and all Evaluators. 
 | 
class  | 
ServiceContextActiveHandlers
Handler for ActiveContext 
 | 
class  | 
ServiceContextClosedHandlers
Handler for ClosedContext. 
 | 
class  | 
ServiceContextFailedHandlers
Handler for FailedContext 
 | 
class  | 
ServiceContextMessageHandlers
Context message handler. 
 | 
class  | 
ServiceDriverRestartCompletedHandlers
Service handler for driver restart completed event 
 | 
class  | 
ServiceDriverRestartContextActiveHandlers
Handler for ActiveContext received during driver restart 
 | 
class  | 
ServiceDriverRestartTaskRunningHandlers
Running task handler during driver restart. 
 | 
class  | 
ServiceEvaluatorAllocatedHandlers
Called when an allocated evaluator is given to the client. 
 | 
class  | 
ServiceEvaluatorCompletedHandlers
Called when an exception occurs on a running evaluator. 
 | 
class  | 
ServiceEvaluatorFailedHandlers
Called when an exception occurs on a running evaluator. 
 | 
class  | 
ServiceTaskCompletedHandlers
Completed task handler. 
 | 
class  | 
ServiceTaskFailedHandlers
Task failure handler. 
 | 
class  | 
ServiceTaskMessageHandlers
Task message handler. 
 | 
class  | 
ServiceTaskRunningHandlers
Running task handler. 
 | 
class  | 
ServiceTaskSuspendedHandlers
Suspended task handler. 
 | 
class  | 
TaskCompletedHandlers
Completed task handler. 
 | 
class  | 
TaskFailedHandlers
Task failure handler. 
 | 
class  | 
TaskMessageHandlers
Task message handler. 
 | 
class  | 
TaskRunningHandlers
Running task handler. 
 | 
class  | 
TaskSuspendedHandlers
Suspended task handler. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
TaskConfigurationOptions.CloseHandler  | 
static class  | 
TaskConfigurationOptions.Identifier  | 
class  | 
TaskConfigurationOptions.Memento  | 
class  | 
TaskConfigurationOptions.MessageHandler  | 
class  | 
TaskConfigurationOptions.StartHandlers  | 
class  | 
TaskConfigurationOptions.StopHandlers  | 
class  | 
TaskConfigurationOptions.SuspendHandler  | 
class  | 
TaskConfigurationOptions.TaskMessageSources  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
ContextIdentifier
Context identifier. 
 | 
class  | 
ContextMessageHandlers
The set of Context message handlers. 
 | 
class  | 
ContextMessageSources
The set of ContextMessageSource implementations called during heartbeats. 
 | 
class  | 
ContextStartHandlers
The set of event handlers for the ContextStart event. 
 | 
class  | 
ContextStopHandlers
The set of event handlers for the ContextStop event. 
 | 
class  | 
Services
A set of classes to be instantiated and shared as singletons within this context and all child context 
 | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
DataLoadingREEF.InputDir  | 
static class  | 
DataLoadingREEF.Local
Command line parameter = true to run locally, or false to run on YARN. 
 | 
static class  | 
DataLoadingREEF.TimeOut  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
Command
Command line parameter: a command to run. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
Launch.Delay
Command line parameter: number of experiments to run. 
 | 
static class  | 
Launch.JobId
Command line parameter = Numeric ID for the job. 
 | 
static class  | 
Launch.Local
Command line parameter = true to run locally, or false to run on YARN. 
 | 
static class  | 
Launch.NumEvaluators
Command line parameter: number of Evaluators to request. 
 | 
static class  | 
Launch.NumTasks
Command line parameter: number of Tasks to run. 
 | 
static class  | 
Launch.Piggyback
Command line parameter = true to submit task and context in one request. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
Launch.Local
Command line parameter = true to run locally, or false to run on YARN. 
 | 
static class  | 
Launch.NumEval
Command line parameter: number of evaluators to allocate. 
 | 
static class  | 
Launch.NumRuns
Command line parameter: number of experiments to run. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
Launch.Command
Command line parameter: a command to run. 
 | 
static class  | 
Launch.Local
Command line parameter = true to run locally, or false to run on YARN. 
 | 
static class  | 
Launch.NumRuns
Command line parameter: number of experiments to run. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
SchedulerREEF.Retain
Command line parameter = true to reuse evaluators,
 or false to allocate/close for each iteration 
 | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
Control.Command  | 
static class  | 
Control.TaskId  | 
static class  | 
Launch.Delay
Command line parameter: delay in seconds for each cycle. 
 | 
static class  | 
Launch.Local
Command line parameter = true to run locally, or false to run on YARN. 
 | 
static class  | 
Launch.NumCycles
Command line parameter: number of iterations to run. 
 | 
static class  | 
SuspendClientControl.Port  | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
RandomNameCNS.PREFIX  | 
static class  | 
SimpleNamingService.CheckpointName
Prefix for checkpoints. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
DataLoadingRequestBuilder.DataLoadingComputeRequest  | 
static class  | 
DataLoadingRequestBuilder.DataLoadingEvaluatorMemoryMB  | 
static class  | 
DataLoadingRequestBuilder.DataLoadingEvaluatorNumberOfCores  | 
static class  | 
DataLoadingRequestBuilder.LoadDataIntoMemory  | 
static class  | 
DataLoadingRequestBuilder.NumberOfDesiredSplits  | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
InputSplitExternalConstructor.SerializedInputSplit  | 
static class  | 
JobConfExternalConstructor.InputFormatClass  | 
static class  | 
JobConfExternalConstructor.InputPath  | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
NetworkServiceParameters.NetworkServiceCodec  | 
static class  | 
NetworkServiceParameters.NetworkServiceExceptionHandler  | 
static class  | 
NetworkServiceParameters.NetworkServiceHandler  | 
static class  | 
NetworkServiceParameters.NetworkServiceIdentifierFactory  | 
static class  | 
NetworkServiceParameters.NetworkServicePort  | 
static class  | 
NetworkServiceParameters.NetworkServiceTransportFactory  | 
static class  | 
NetworkServiceParameters.TaskId  | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
NameLookupClient.RetryCount  | 
static class  | 
NameLookupClient.RetryTimeout  | 
class  | 
NameServerParameters.NameServerAddr  | 
class  | 
NameServerParameters.NameServerIdentifierFactory  | 
class  | 
NameServerParameters.NameServerPort  | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
CodecRamMap.RamMapCodec  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
CrashProbability
The probability with which a crash will occur. 
 | 
class  | 
CrashTimeout  | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
REEFImplementation.DriverRemoteIdentifier  | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
ClientRuntimeParameters.RuntimeErrorHandlerRID  | 
| 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 | 
|---|---|
static class  | 
DriverRuntimeConfigurationOptions.JobControlHandler  | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
AbstractDriverRuntimeConfiguration.ClientRemoteIdentifier
Deprecated.  
  | 
static class  | 
AbstractDriverRuntimeConfiguration.DriverProcessMemory
Deprecated.  
This parameter denotes that the driver process should actually be
 started in a separate process with the given amount of JVM memory. 
 | 
static class  | 
AbstractDriverRuntimeConfiguration.EvaluatorTimeout
Deprecated.  
  | 
static class  | 
AbstractDriverRuntimeConfiguration.JobIdentifier
Deprecated.  
  | 
static class  | 
RuntimeParameters.NodeDescriptorHandler  | 
static class  | 
RuntimeParameters.ResourceAllocationHandler  | 
static class  | 
RuntimeParameters.ResourceStatusHandler  | 
static class  | 
RuntimeParameters.RuntimeStatusHandler  | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
EvaluatorManager.EvaluatorDescriptorName  | 
static class  | 
EvaluatorManager.EvaluatorIdentifier  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
ApplicationIdentifier
The RM application/job identifier. 
 | 
class  | 
DriverRemoteIdentifier
The identifier used by the Evaluator to connect back to the Driver. 
 | 
class  | 
EvaluatorIdentifier
The evaluator identifier. 
 | 
class  | 
HeartbeatPeriod
The evaluator heartbeat period in ms. 
 | 
class  | 
InitialTaskConfiguration
An initial task to launch on startup. 
 | 
class  | 
RootContextConfiguration
The evaluator root context configuration. 
 | 
class  | 
RootServiceConfiguration
The service configuration for the root context 
 | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
LaunchClass.ProfilingEnabled  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
ClockConfigurationPath
The path to the clock configuration 
 | 
class  | 
ErrorHandlerRID  | 
class  | 
LaunchID  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
DeleteTempFiles
Whether or not to delete the temporary files created during Driver and Evaluator submission. 
 | 
class  | 
JVMHeapSlack
The fraction of the container memory NOT to use for the Java Heap. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
AzureStorageAccountContainerName
The Storage account container name to be used by Azure. 
 | 
class  | 
AzureStorageAccountKey
The Storage account key to be used by Azure. 
 | 
class  | 
AzureStorageAccountName
The Storage account to be used by Azure. 
 | 
class  | 
AzureStorageBaseFolder
The folder to use as the base folder for storing the JARs. 
 | 
class  | 
HDInsightInstanceURL
The password to be used for connecting to hdinsight. 
 | 
class  | 
HDInsightPassword
The password to be used for connecting to hdinsight. 
 | 
class  | 
HDInsightUsername
The username to be used for connecting to hdinsight. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
DefaultMemorySize
The size of the default container returned in MB. 
 | 
class  | 
DefaultNumberOfCores
The number of the default core. 
 | 
class  | 
NumberOfProcesses
The maximum number of processes to use at once 
 | 
class  | 
RootFolder
The folder where logs etc. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
GlobalFiles
The names of files that are to be copied to all evaluators. 
 | 
class  | 
GlobalLibraries
The names of files that are to be copied to all evaluators. 
 | 
class  | 
LocalFiles
Created by marku_000 on 2014-07-07. 
 | 
class  | 
LocalLibraries
The names of files that are to be kept on the driver only. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
JobPriority
The prioroty of the submitted job. 
 | 
class  | 
JobQueue
The queue to submit a job to. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
JobSubmissionDirectory
The job submission directory. 
 | 
class  | 
YarnHeartbeatPeriod
How often we talk to YARN. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
Timer.Seconds  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
ValidateConfiguration.ClassHierarchyIn  | 
class  | 
ValidateConfiguration.ConfigurationIn  | 
class  | 
ValidateConfiguration.ConfigurationOut  | 
class  | 
ValidateConfiguration.Target  | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
FailDriver.FailMsgClassName
Name of the message class to specify the failing message handler. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
Driver.FailTaskName
Name of the message class to specify the failing message handler. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
FailureREEF.Local
Command line parameter = true to run locally, or false to run on YARN. 
 | 
static class  | 
FailureREEF.TimeOut  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
LogLevelName
Name of a log Level as a string such as "INFO", "FINE" 
 | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
StageConfiguration.Capacity  | 
static class  | 
StageConfiguration.ErrorHandler  | 
static class  | 
StageConfiguration.NumberOfThreads  | 
static class  | 
StageConfiguration.StageExecutorService  | 
static class  | 
StageConfiguration.StageHandler  | 
static class  | 
StageConfiguration.StageName  | 
static class  | 
StageConfiguration.StageObserver  | 
static class  | 
StageConfiguration.TimerInitialDelay  | 
static class  | 
StageConfiguration.TimerPeriod  | 
static class  | 
WakeConfiguration.FileName  | 
static class  | 
WakeParameters.ExecutorShutdownTimeout  | 
static class  | 
WakeParameters.MaxFrameLength  | 
static class  | 
WakeParameters.RemoteSendTimeout  | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
RemoteConfiguration.ErrorHandler  | 
static class  | 
RemoteConfiguration.HostAddress  | 
static class  | 
RemoteConfiguration.ManagerName  | 
static class  | 
RemoteConfiguration.MessageCodec  | 
static class  | 
RemoteConfiguration.NumberOfTries  | 
static class  | 
RemoteConfiguration.OrderingGuarantee  | 
static class  | 
RemoteConfiguration.Port  | 
static class  | 
RemoteConfiguration.RetryTimeout  | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
Clock.IdleHandler
Bind this to an event handler to statically subscribe to the IdleClock Event 
 | 
static class  | 
Clock.RuntimeStartHandler
Bind this to an event handler to statically subscribe to the RuntimeStart Event 
 | 
static class  | 
Clock.RuntimeStopHandler
Bind this to an event handler to statically subscribe to the RuntimeStart Event 
 | 
static class  | 
Clock.StartHandler
Bind this to an event handler to statically subscribe to the StartTime Event 
 | 
static class  | 
Clock.StopHandler
Bind this to an event handler to statically subscribe to the StopTime Event 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
HttpEventHandlers
HttpEventHandlers 
 | 
class  | 
MaxPortNumber
max port number range when generating a port number for the Http Server 
 | 
class  | 
MaxRetryAttempts
Max retry times when generating a port number for the Http Server 
 | 
class  | 
MinPortNumber
minimum port number range when generating a port number for the Http Server 
 | 
class  | 
PortNumber
port number for the Http Server
 Clients can set a preferred port number. 
 | 
Copyright © 2015 The Apache Software Foundation. All rights reserved.