| ApplicationEnd |
The ApplicationEnd class represents an application that has ended.
|
| ApplicationStart |
The ApplicationStart class implements the Application and SerializableObject interfaces.
|
| ExecutorAdded |
The ExecutorAdded class represents an executor added event in a distributed computing system.
|
| ExecutorRemoved |
An event class representing the removal of an executor.
|
| ExecutorUpdated |
An implementation of the Executor interface that represents an updated executor.
|
| JobEnd |
JobEnd class represents a job's end in a system.
|
| JobStart |
JobStart class represents a job's start in a system.
|
| SparkListener |
A Spark listener implementation that captures events generated during the Spark job execution
and sends them to a Kafka topic for further processing.
|
| StageCompleted |
Represents a completed stage in a distributed computing system.
|
| StageExecutorMetrics |
The StageExecutorMetrics class implements the Stage and SerializableObject interfaces and represents
the metrics associated with a stage executed by an executor.
|
| StageSubmitted |
The StageSubmitted class implements the Stage and SerializableObject interfaces to represent a submitted stage in a distributed system.
|
| TaskEnd |
Represents the end status of a task execution.
|
| TaskGettingResult |
Represents the getting results of a task execution.
|
| TaskMetric |
This class represents the metrics for a task in the Apache Wayang monitoring system.
|
| TaskStart |
Represents the start status of a task execution.
|