StandaloneAppClientListener¶

StandaloneAppClientListener is an abstraction of listeners.

Contract¶

connected¶

connected(
  appId: String): Unit

Used when:

• ClientEndpoint is requested to handle a RegisteredApplication message

dead¶

dead(
  reason: String): Unit

Used when:

• ClientEndpoint is requested to markDead

disconnected¶

disconnected(): Unit

Used when:

• ClientEndpoint is requested to markDisconnected

executorAdded¶

executorAdded(
  fullId: String,
  workerId: String,
  hostPort: String,
  cores: Int,
  memory: Int): Unit

Used when:

• ClientEndpoint is requested to handle a ExecutorAdded message

executorDecommissioned¶

executorDecommissioned(
  fullId: String,
  decommissionInfo: ExecutorDecommissionInfo): Unit

Used when:

• ClientEndpoint is requested to handle a ExecutorUpdated message

executorRemoved¶

executorRemoved(
  fullId: String,
  message: String,
  exitStatus: Option[Int],
  workerHost: Option[String]): Unit

Used when:

• ClientEndpoint is requested to handle a ExecutorUpdated message

workerRemoved¶

workerRemoved(
  workerId: String,
  host: String,
  message: String): Unit

Used when:

• ClientEndpoint is requested to handle a WorkerRemoved message

Implementations¶

• StandaloneSchedulerBackend