| 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 |
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.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.
|
| 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.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 | Method and Description |
|---|---|
<T> JavaConfigurationBuilder |
JavaConfigurationBuilder.bindList(Class<? extends Name<List<T>>> iface,
List impl)
Binds a specfic list to a named parameter.
|
JavaConfigurationBuilder |
JavaConfigurationBuilder.bindNamedParameter(Class<? extends Name<?>> name,
String value)
Set the value of a named parameter.
|
<T> JavaConfigurationBuilder |
JavaConfigurationBuilder.bindNamedParameter(Class<? extends Name<T>> iface,
Class<? extends T> impl) |
<T> JavaConfigurationBuilder |
JavaConfigurationBuilder.bindSetEntry(Class<? extends Name<Set<T>>> iface,
Class<? extends T> impl) |
<T> JavaConfigurationBuilder |
JavaConfigurationBuilder.bindSetEntry(Class<? extends Name<Set<T>>> iface,
String value) |
<T> void |
Injector.bindVolatileParameter(Class<? extends Name<T>> iface,
T inst) |
<U> U |
Injector.getNamedInstance(Class<? extends Name<U>> iface)
Gets the value stored for the given named parameter.
|
boolean |
Injector.isParameterSet(Class<? extends Name<?>> name) |
| Modifier and Type | Class and Description |
|---|---|
static class |
Timer.Seconds |
| Modifier and Type | Method and Description |
|---|---|
<T> ConfigurationModuleBuilder |
ConfigurationModuleBuilder.bindList(Class<? extends Name<List<T>>> iface,
Impl<List> opt) |
<T> ConfigurationModuleBuilder |
ConfigurationModuleBuilder.bindList(Class<? extends Name<List<T>>> iface,
List list) |
<T> ConfigurationModuleBuilder |
ConfigurationModuleBuilder.bindList(Class<? extends Name<List<T>>> iface,
Param<List> opt) |
<T> ConfigurationModuleBuilder |
ConfigurationModuleBuilder.bindNamedParameter(Class<? extends Name<T>> iface,
Class<? extends T> impl) |
<T> ConfigurationModuleBuilder |
ConfigurationModuleBuilder.bindNamedParameter(Class<? extends Name<T>> iface,
Impl<? extends T> opt) |
<T> ConfigurationModuleBuilder |
ConfigurationModuleBuilder.bindNamedParameter(Class<? extends Name<T>> name,
Param<T> opt) |
<T> ConfigurationModuleBuilder |
ConfigurationModuleBuilder.bindNamedParameter(Class<? extends Name<T>> name,
String value) |
<T> ConfigurationModuleBuilder |
ConfigurationModuleBuilder.bindSetEntry(Class<? extends Name<Set<T>>> iface,
Class<? extends T> impl) |
<T> ConfigurationModuleBuilder |
ConfigurationModuleBuilder.bindSetEntry(Class<? extends Name<Set<T>>> iface,
Impl<? extends T> opt) |
<T> ConfigurationModuleBuilder |
ConfigurationModuleBuilder.bindSetEntry(Class<? extends Name<Set<T>>> iface,
Param<? extends T> opt) |
<T> ConfigurationModuleBuilder |
ConfigurationModuleBuilder.bindSetEntry(Class<? extends Name<Set<T>>> iface,
String impl) |
CommandLine |
CommandLine.registerShortNameOfClass(Class<? extends Name<?>> c) |
| Modifier and Type | Method and Description |
|---|---|
<T> JavaConfigurationBuilder |
JavaConfigurationBuilderImpl.bindList(Class<? extends Name<List<T>>> iface,
List implList)
Binding list method for JavaConfigurationBuilder.
|
JavaConfigurationBuilder |
JavaConfigurationBuilderImpl.bindNamedParameter(Class<? extends Name<?>> name,
String value) |
<T> JavaConfigurationBuilder |
JavaConfigurationBuilderImpl.bindNamedParameter(Class<? extends Name<T>> iface,
Class<? extends T> impl) |
<T> JavaConfigurationBuilder |
JavaConfigurationBuilderImpl.bindSetEntry(Class<? extends Name<Set<T>>> iface,
Class<? extends T> impl) |
<T> JavaConfigurationBuilder |
JavaConfigurationBuilderImpl.bindSetEntry(Class<? extends Name<Set<T>>> iface,
String value) |
<T> void |
InjectorImpl.bindVolatileParameter(Class<? extends Name<T>> c,
T o) |
static <T> NamedParameterNode<T> |
JavaNodeFactory.createNamedParameterNode(Node parent,
Class<? extends Name<T>> clazz,
Type argClass)
XXX: This method assumes that all generic types have exactly one type parameter.
|
<T> T |
InjectorImpl.getNamedInstance(Class<? extends Name<T>> clazz) |
<T> T |
InjectorImpl.getNamedParameter(Class<? extends Name<T>> clazz) |
boolean |
InjectorImpl.isParameterSet(Class<? extends Name<?>> name) |
| 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.