Package | Description |
---|---|
org.apache.reef.client |
Client APIs for REEF.
|
org.apache.reef.driver.context |
Driver Contexts and their configurations.
|
org.apache.reef.driver.task |
Tasks and their configurations.
|
org.apache.reef.io.watcher |
Watcher subscribes events and writes them to the destination using a certain EventStream.
|
org.apache.reef.runtime.local.client |
Client-side event handlers for the local resourcemanager.
|
org.apache.reef.runtime.standalone.client |
Client-side event handlers for the standalone 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.
|
Modifier and Type | Field and Description |
---|---|
static OptionalImpl<EventHandler<Void>> |
DriverConfiguration.ON_CLIENT_CLOSED
Event handler for close messages sent by the client.
|
static OptionalImpl<EventHandler<byte[]>> |
DriverConfiguration.ON_CLIENT_CLOSED_MESSAGE
Event handler for close messages sent by the client.
|
static OptionalImpl<EventHandler<byte[]>> |
DriverConfiguration.ON_CLIENT_MESSAGE
Event handler for client messages.
|
static OptionalImpl<EventHandler<ActiveContext>> |
DriverServiceConfiguration.ON_CONTEXT_ACTIVE
Event handler for active context.
|
static OptionalImpl<EventHandler<ActiveContext>> |
DriverConfiguration.ON_CONTEXT_ACTIVE
Event handler for active context.
|
static OptionalImpl<EventHandler<ClosedContext>> |
DriverServiceConfiguration.ON_CONTEXT_CLOSED
Event handler for closed context.
|
static OptionalImpl<EventHandler<ClosedContext>> |
DriverConfiguration.ON_CONTEXT_CLOSED
Event handler for closed context.
|
static OptionalImpl<EventHandler<FailedContext>> |
DriverServiceConfiguration.ON_CONTEXT_FAILED
Event handler for closed context.
|
static OptionalImpl<EventHandler<FailedContext>> |
DriverConfiguration.ON_CONTEXT_FAILED
Event handler for closed context.
|
static OptionalImpl<EventHandler<ContextMessage>> |
DriverServiceConfiguration.ON_CONTEXT_MESSAGE
Event handler for context messages.
|
static OptionalImpl<EventHandler<ContextMessage>> |
DriverConfiguration.ON_CONTEXT_MESSAGE
Event handler for context messages.
|
static OptionalImpl<EventHandler<DriverRestartCompleted>> |
DriverRestartConfiguration.ON_DRIVER_RESTART_COMPLETED
Event handler for the event of driver restart completion, default to logging if not bound.
|
static OptionalImpl<EventHandler<ActiveContext>> |
DriverRestartConfiguration.ON_DRIVER_RESTART_CONTEXT_ACTIVE
Event handler for active context when driver restart.
|
static OptionalImpl<EventHandler<FailedEvaluator>> |
DriverRestartConfiguration.ON_DRIVER_RESTART_EVALUATOR_FAILED
Event handler for the event of driver restart completion, default to logging if not bound.
|
static OptionalImpl<EventHandler<RunningTask>> |
DriverRestartConfiguration.ON_DRIVER_RESTART_TASK_RUNNING
Event handler for running tasks in previous evaluator, when driver restarted.
|
static OptionalImpl<EventHandler<DriverRestarted>> |
DriverServiceConfiguration.ON_DRIVER_RESTARTED
The event handler invoked right after the driver restarts.
|
static OptionalImpl<EventHandler<DriverRestarted>> |
DriverRestartConfiguration.ON_DRIVER_RESTARTED
This event is fired in place of the ON_DRIVER_STARTED when the Driver is in fact restarted after failure.
|
static OptionalImpl<EventHandler<StopTime>> |
DriverServiceConfiguration.ON_DRIVER_STOP
The event handler invoked right before the driver shuts down.
|
static OptionalImpl<EventHandler<StopTime>> |
DriverConfiguration.ON_DRIVER_STOP
The event handler invoked right before the driver shuts down.
|
static OptionalImpl<EventHandler<AllocatedEvaluator>> |
DriverServiceConfiguration.ON_EVALUATOR_ALLOCATED
Event handler for allocated evaluators.
|
static OptionalImpl<EventHandler<AllocatedEvaluator>> |
DriverConfiguration.ON_EVALUATOR_ALLOCATED
Event handler for allocated evaluators.
|
static OptionalImpl<EventHandler<CompletedEvaluator>> |
DriverServiceConfiguration.ON_EVALUATOR_COMPLETED
Event handler for completed evaluators.
|
static OptionalImpl<EventHandler<CompletedEvaluator>> |
DriverConfiguration.ON_EVALUATOR_COMPLETED
Event handler for completed evaluators.
|
static OptionalImpl<EventHandler<FailedEvaluator>> |
DriverServiceConfiguration.ON_EVALUATOR_FAILED
Event handler for failed evaluators.
|
static OptionalImpl<EventHandler<FailedEvaluator>> |
DriverConfiguration.ON_EVALUATOR_FAILED
Event handler for failed evaluators.
|
static OptionalImpl<EventHandler<CompletedJob>> |
ClientConfiguration.ON_JOB_COMPLETED
Handler for the event when a submitted REEF Job is completed.
|
static OptionalImpl<EventHandler<FailedJob>> |
ClientConfiguration.ON_JOB_FAILED
Handler for the event when a submitted REEF Job has failed.
|
static OptionalImpl<EventHandler<JobMessage>> |
ClientConfiguration.ON_JOB_MESSAGE
Event handler for messages from the running job.
|
static OptionalImpl<EventHandler<RunningJob>> |
ClientConfiguration.ON_JOB_RUNNING
Handler for the event when a submitted REEF Job is running.
|
static OptionalImpl<EventHandler<FailedRuntime>> |
ClientConfiguration.ON_RUNTIME_ERROR
Receives fatal resourcemanager errors.
|
static OptionalImpl<EventHandler<CompletedTask>> |
DriverServiceConfiguration.ON_TASK_COMPLETED
Event handler for completed tasks.
|
static OptionalImpl<EventHandler<CompletedTask>> |
DriverConfiguration.ON_TASK_COMPLETED
Event handler for completed tasks.
|
static OptionalImpl<EventHandler<FailedTask>> |
DriverServiceConfiguration.ON_TASK_FAILED
Event handler for failed tasks.
|
static OptionalImpl<EventHandler<FailedTask>> |
DriverConfiguration.ON_TASK_FAILED
Event handler for failed tasks.
|
static OptionalImpl<EventHandler<TaskMessage>> |
DriverServiceConfiguration.ON_TASK_MESSAGE
Event handler for task messages.
|
static OptionalImpl<EventHandler<TaskMessage>> |
DriverConfiguration.ON_TASK_MESSAGE
Event handler for task messages.
|
static OptionalImpl<EventHandler<RunningTask>> |
DriverServiceConfiguration.ON_TASK_RUNNING
Event handler for running tasks.
|
static OptionalImpl<EventHandler<RunningTask>> |
DriverConfiguration.ON_TASK_RUNNING
Event handler for running tasks.
|
static OptionalImpl<EventHandler<SuspendedTask>> |
DriverServiceConfiguration.ON_TASK_SUSPENDED
Event handler for suspended tasks.
|
static OptionalImpl<EventHandler<SuspendedTask>> |
DriverConfiguration.ON_TASK_SUSPENDED
Event handler for suspended tasks.
|
static OptionalImpl<EventHandler<Throwable>> |
ClientConfiguration.ON_WAKE_ERROR
Error handler for events on Wake-spawned threads.
|
static OptionalImpl<ProgressProvider> |
DriverConfiguration.PROGRESS_PROVIDER
Progress provider.
|
Modifier and Type | Field and Description |
---|---|
static OptionalImpl<EventHandler<ContextStart>> |
ServiceConfiguration.ON_CONTEXT_STARTED
Event handler for context start.
|
static OptionalImpl<EventHandler<ContextStart>> |
ContextConfiguration.ON_CONTEXT_STARTED
Event handler for context start.
|
static OptionalImpl<EventHandler<ContextStop>> |
ServiceConfiguration.ON_CONTEXT_STOP
Event handler for context stop.
|
static OptionalImpl<EventHandler<ContextStop>> |
ContextConfiguration.ON_CONTEXT_STOP
Event handler for context stop.
|
static OptionalImpl<DriverConnection> |
ContextConfiguration.ON_DRIVER_RECONNECT
Implementation for reconnecting to driver after driver restart.
|
static OptionalImpl<ContextMessageHandler> |
ContextConfiguration.ON_MESSAGE
Driver has sent the context a message, and this parameter is used to register a handler
on the context for processing that message.
|
static OptionalImpl<ContextMessageSource> |
ContextConfiguration.ON_SEND_MESSAGE
Source of messages to be called whenever the evaluator is about to make a heartbeat.
|
static OptionalImpl<EventHandler<TaskStart>> |
ServiceConfiguration.ON_TASK_STARTED
Event handlers to be informed right before a Task enters its call() method.
|
static OptionalImpl<EventHandler<TaskStart>> |
ContextConfiguration.ON_TASK_STARTED
Event handlers to be informed right before a Task enters its call() method.
|
static OptionalImpl<EventHandler<TaskStop>> |
ServiceConfiguration.ON_TASK_STOP
Event handlers to be informed right after a Task exits its call() method.
|
static OptionalImpl<EventHandler<TaskStop>> |
ContextConfiguration.ON_TASK_STOP
Event handlers to be informed right after a Task exits its call() method.
|
Modifier and Type | Field and Description |
---|---|
static OptionalImpl<EventHandler<CloseEvent>> |
TaskConfiguration.ON_CLOSE
Handler for closure requests from the driver.
|
static OptionalImpl<EventHandler<DriverMessage>> |
TaskConfiguration.ON_MESSAGE
Handler for messages from the driver.
|
static OptionalImpl<TaskMessageSource> |
TaskConfiguration.ON_SEND_MESSAGE
Message source invoked upon each evaluator heartbeat.
|
static OptionalImpl<EventHandler<SuspendEvent>> |
TaskConfiguration.ON_SUSPEND
Handler for task suspension.
|
static OptionalImpl<EventHandler<TaskStart>> |
TaskConfiguration.ON_TASK_STARTED
Event handler to receive TaskStart after the Task.call() method was called.
|
static OptionalImpl<EventHandler<TaskStop>> |
TaskConfiguration.ON_TASK_STOP
Event handler to receive TaskStop after the Task.call() method returned.
|
Modifier and Type | Field and Description |
---|---|
static OptionalImpl<EventStream> |
WatcherConfiguration.EVENT_STREAMS
Types of EventStream where events subscribed by Watcher will be reported.
|
Modifier and Type | Field and Description |
---|---|
static OptionalImpl<ConfigurationProvider> |
LocalRuntimeConfiguration.DRIVER_CONFIGURATION_PROVIDERS
Configuration provides whose Configuration will be merged into all Driver Configuration.
|
static OptionalImpl<ConfigurationProvider> |
ExtensibleLocalRuntimeConfiguration.DRIVER_CONFIGURATION_PROVIDERS
Configuration provides whose Configuration will be merged into all Driver Configuration.
|
Modifier and Type | Field and Description |
---|---|
static OptionalImpl<ConfigurationProvider> |
StandaloneRuntimeConfiguration.DRIVER_CONFIGURATION_PROVIDERS
Configuration provides whose Configuration will be merged into all Driver Configuration.
|
Modifier and Type | Field and Description |
---|---|
static OptionalImpl<ConfigurationProvider> |
YarnClientConfiguration.DRIVER_CONFIGURATION_PROVIDERS
Configuration provides whose Configuration will be merged into all Driver Configuration.
|
static OptionalImpl<ConfigurationProvider> |
ExtensibleYarnClientConfiguration.DRIVER_CONFIGURATION_PROVIDERS
Configuration provides whose Configuration will be merged into all Driver Configuration.
|
Modifier and Type | Field and Description |
---|---|
static OptionalImpl<EvaluatorPreserver> |
YarnDriverRestartConfiguration.EVALUATOR_PRESERVER
The Evaluator Preserver implementation used for YARN.
|
static OptionalImpl<RackNameFormatter> |
YarnDriverConfiguration.RACK_NAME_FORMATTER |
Copyright © 2016 The Apache Software Foundation. All rights reserved.