SparkMonitor JavaScript Documentation

Class: TaskChart

TaskChart~ TaskChart

new TaskChart(cellmonitor)

Adds a chart with number of active tasks and executor cores to the monitoring display
Parameters:
Name Type Description
cellmonitor CellMonitor The parent CellMonitor to render in.

Methods

create()

Creates and renders the Task Chart

addData(time, numTasks)

Add a data point to the Task Chart
Parameters:
Name Type Description
time Date The x axis value of time
numTasks number Number of active tasks

addExecutorData(time, numCores)

Add a data point to the executors trace.
Parameters:
Name Type Description
time Date The x axis value of time
numCores number Number of executor cores

hide()

Hides the TaskChart.

registerRefresher()

Registers a refresher to update the TaskChart.

refreshTaskChart()

Refreshed the TaskChart.

clearRefresher()

Removes the TaskChart Refresher.

onAllCompleted()

Called when all cell execution is completed and all jobs have completed.

addJobData(jobId, time, event)

Add a data point to the job trace.
Parameters:
Name Type Description
jobId string The JobId
time Data The time of event
event string "started" or "ended"

onSparkJobStart()

Called when a Spark job starts.

onSparkJobEnd()

Called when a Spark job ends.

onSparkStageSubmitted()

Called when a Spark stage is submitted.

onSparkStageCompleted()

Called when a Spark stage is completed.

onSparkTaskStart()

Called when a Spark task is started.

onSparkTaskEnd()

Called when a Spark task is ended.