public abstract class AbstractMesosServices extends Object implements MesosServices
MesosServices
.Modifier | Constructor and Description |
---|---|
protected |
AbstractMesosServices(akka.actor.ActorSystem actorSystem,
MesosArtifactServer artifactServer) |
Modifier and Type | Method and Description |
---|---|
void |
close(boolean cleanup)
Closes all state maintained by the mesos services implementation.
|
MesosResourceManagerActorFactory |
createMesosResourceManagerActorFactory()
Gets a
MesosResourceManagerActorFactory which creates child actors within MesosResourceManagerDriver in a local ActorSystem . |
org.apache.mesos.SchedulerDriver |
createMesosSchedulerDriver(MesosConfiguration mesosConfig,
org.apache.mesos.Scheduler scheduler,
boolean implicitAcknowledgements)
Create the Mesos scheduler driver.
|
MesosArtifactServer |
getArtifactServer()
Gets the artifact server with which to serve essential resources to task managers.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createMesosWorkerStore
protected AbstractMesosServices(akka.actor.ActorSystem actorSystem, MesosArtifactServer artifactServer)
public MesosResourceManagerActorFactory createMesosResourceManagerActorFactory()
MesosServices
MesosResourceManagerActorFactory
which creates child actors within MesosResourceManagerDriver
in a local ActorSystem
.createMesosResourceManagerActorFactory
in interface MesosServices
public MesosArtifactServer getArtifactServer()
MesosServices
getArtifactServer
in interface MesosServices
public org.apache.mesos.SchedulerDriver createMesosSchedulerDriver(MesosConfiguration mesosConfig, org.apache.mesos.Scheduler scheduler, boolean implicitAcknowledgements)
MesosServices
createMesosSchedulerDriver
in interface MesosServices
mesosConfig
- configuration of the schedulerscheduler
- the scheduler to use.implicitAcknowledgements
- whether to configure the driver for implicit
acknowledgements.public void close(boolean cleanup) throws Exception
MesosServices
close
in interface MesosServices
cleanup
- is true if a cleanup shall be performedException
- if the closing operation failedCopyright © 2014–2021 The Apache Software Foundation. All rights reserved.