deploylib.mesos

LocalExperimentScheduler

class LocalExperimentScheduler extends Scheduler with ExperimentScheduler

Linear Supertypes
ExperimentScheduler, Scheduler, AnyRef, Any
Known Subclasses
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. LocalExperimentScheduler
  2. ExperimentScheduler
  3. Scheduler
  4. AnyRef
  5. Any
Visibility
  1. Public
  2. All

Instance Constructors

  1. new LocalExperimentScheduler (name: String, mesosMaster: String, executor: String)

    Attributes
    protected

Type Members

  1. case class Experiment (processes: Seq[JvmTask]) extends Product with Serializable

Value Members

  1. def != (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  2. def != (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any
  3. def ## (): Int

    Attributes
    final
    Definition Classes
    AnyRef → Any
  4. def == (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  5. def == (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any
  6. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any
  7. var awaitingSiblings : List[JvmTask]

  8. def clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  9. var driver : MesosSchedulerDriver

  10. val driverThread : Thread

  11. def eq (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  12. def equals (arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  13. def error (driver: SchedulerDriver, code: Int, message: String): Unit

    Definition Classes
    LocalExperimentScheduler → Scheduler
  14. val executorId : Builder

  15. def finalize (): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  16. def frameworkMessage (driver: SchedulerDriver, slaveId: SlaveID, executor: ExecutorID, data: Array[Byte]): Unit

    Definition Classes
    LocalExperimentScheduler → Scheduler
  17. def getClass (): java.lang.Class[_]

    Attributes
    final
    Definition Classes
    AnyRef → Any
  18. def getExecutorInfo (d: SchedulerDriver): ExecutorInfo

    Definition Classes
    LocalExperimentScheduler → Scheduler
  19. def getFrameworkName (d: SchedulerDriver): String

    Definition Classes
    LocalExperimentScheduler → Scheduler
  20. def hashCode (): Int

    Definition Classes
    AnyRef → Any
  21. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any
  22. val logger : Logger

  23. def ne (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  24. def notify (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  25. def notifyAll (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  26. def offerRescinded (driver: SchedulerDriver, oid: OfferID): Unit

    Definition Classes
    LocalExperimentScheduler → Scheduler
  27. var outstandingExperiments : ConcurrentLinkedQueue[Experiment]

  28. def registered (d: SchedulerDriver, fid: FrameworkID): Unit

    Definition Classes
    LocalExperimentScheduler → Scheduler
  29. def resourceOffer (d: SchedulerDriver, oid: OfferID, offers: List[SlaveOffer]): Unit

    Definition Classes
    LocalExperimentScheduler → Scheduler
  30. def scheduleExperiment (processes: Seq[JvmTask]): Unit

  31. var scheduledExperiments : List[List[TaskID]]

  32. def slaveLost (driver: SchedulerDriver, slaveId: SlaveID): Unit

    Definition Classes
    LocalExperimentScheduler → Scheduler
  33. def statusUpdate (d: SchedulerDriver, status: TaskStatus): Unit

    Definition Classes
    LocalExperimentScheduler → Scheduler
  34. def stopDriver : Int

  35. def synchronized [T0] (arg0: ⇒ T0): T0

    Attributes
    final
    Definition Classes
    AnyRef
  36. def taskDescription (task: JvmTask): String

    Attributes
    protected
  37. var taskId : Int

  38. var taskIds : List[TaskID]

  39. def toString (): String

    Definition Classes
    AnyRef → Any
  40. def wait (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  41. def wait (arg0: Long, arg1: Int): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  42. def wait (arg0: Long): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

Inherited from ExperimentScheduler

Inherited from Scheduler

Inherited from AnyRef

Inherited from Any