Skip to content

Tracker

Tracker is a private internal class of ExecutorMonitor.

Creating Instance

Tracker takes the following to be created:

  • resourceProfileId

Tracker is created when:

cachedBlocks Internal Registry

cachedBlocks: Map[Int, BitSet]

Tracker uses cachedBlocks internal registry for cached blocks (RDD IDs and partition IDs stored in an executor).

cachedBlocks is used when:

removeShuffle

removeShuffle(
  id: Int): Unit

removeShuffle...FIXME

removeShuffle is used when:

updateActiveShuffles

updateActiveShuffles(
  ids: Iterable[Int]): Unit

updateActiveShuffles...FIXME

updateActiveShuffles is used when:

updateRunningTasks

updateRunningTasks(
  delta: Int): Unit

updateRunningTasks...FIXME

updateRunningTasks is used when:

updateTimeout

updateTimeout(): Unit

updateTimeout...FIXME

updateTimeout is used when:


Last update: 2020-12-27