| AccumulableInfo |
Developer API
Information about an Accumulable modified during a task or stage. |
| AllJobsCancelled |
|
| AskPermissionToCommitOutput |
|
| AsyncEventQueue |
An asynchronous queue for events.
|
| BlacklistedExecutor |
|
| ExecutorKilled |
|
| InputFormatInfo |
Developer API
Parses and holds information about inputFormat (and files) specified as a parameter.
|
| JobSucceeded |
|
| LossReasonPending |
A loss reason that means we don't yet know why the executor exited.
|
| ResubmitFailedStages |
|
| RuntimePercentage |
|
| SchedulingMode |
"FAIR" and "FIFO" determines which policy is used
to order tasks amongst a Schedulable's sub-queues
"NONE" is used when the a Schedulable has no sub-queues.
|
| SparkListener |
Developer API
A default implementation for SparkListenerInterface that has no-op implementations for
all callbacks.
|
| SparkListenerApplicationEnd |
|
| SparkListenerApplicationStart |
|
| SparkListenerBlockManagerAdded |
|
| SparkListenerBlockManagerRemoved |
|
| SparkListenerBlockUpdated |
|
| SparkListenerEnvironmentUpdate |
|
| SparkListenerExecutorAdded |
|
| SparkListenerExecutorBlacklisted |
|
| SparkListenerExecutorBlacklistedForStage |
|
| SparkListenerExecutorMetricsUpdate |
Periodic updates from executors.
|
| SparkListenerExecutorRemoved |
|
| SparkListenerExecutorUnblacklisted |
|
| SparkListenerJobEnd |
|
| SparkListenerJobStart |
|
| SparkListenerLogStart |
An internal class that describes the metadata of an event log.
|
| SparkListenerNodeBlacklisted |
|
| SparkListenerNodeBlacklistedForStage |
|
| SparkListenerNodeUnblacklisted |
|
| SparkListenerSpeculativeTaskSubmitted |
|
| SparkListenerStageCompleted |
|
| SparkListenerStageSubmitted |
|
| SparkListenerTaskEnd |
|
| SparkListenerTaskGettingResult |
|
| SparkListenerTaskStart |
|
| SparkListenerUnpersistRDD |
|
| SplitInfo |
|
| StageInfo |
Developer API
Stores information about a stage to pass from the scheduler to SparkListeners.
|
| StatsReportListener |
Developer API
Simple SparkListener that logs a few summary statistics when each stage completes.
|
| StopCoordinator |
|
| TaskInfo |
Developer API
Information about a running task attempt inside a TaskSet.
|
| TaskLocality |
|