Package org.apache.wayang.spark.monitoring.metrics

package org.apache.wayang.spark.monitoring.metrics

Classes

Class	Description
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.