public class MesosResourceManagerActorFactoryImpl extends Object implements MesosResourceManagerActorFactory
MesosResourceManagerActorFactory
.Constructor and Description |
---|
MesosResourceManagerActorFactoryImpl(akka.actor.ActorSystem actorSystem) |
Modifier and Type | Method and Description |
---|---|
akka.actor.ActorRef |
createConnectionMonitor(Configuration flinkConfig)
Create actor for the connection monitor.
|
akka.actor.ActorRef |
createLaunchCoordinator(Configuration flinkConfig,
akka.actor.ActorRef resourceManagerActor,
org.apache.mesos.SchedulerDriver schedulerDriver,
TaskSchedulerBuilder optimizer)
Create actor for the launch coordinator.
|
akka.actor.ActorRef |
createReconciliationCoordinator(Configuration flinkConfig,
org.apache.mesos.SchedulerDriver schedulerDriver)
Create actor for the reconciliation coordinator.
|
akka.actor.ActorRef |
createSelfActorForMesosResourceManagerDriver(MesosResourceManagerDriver self)
Create self actor for mesos resource manager.
|
akka.actor.ActorRef |
createTaskMonitor(Configuration flinkConfig,
akka.actor.ActorRef resourceManagerActor,
org.apache.mesos.SchedulerDriver schedulerDriver)
Create actor for the task monitor.
|
CompletableFuture<Boolean> |
stopActor(akka.actor.ActorRef actorRef,
scala.concurrent.duration.FiniteDuration timeout)
Tries to shut down the given actor gracefully.
|
public MesosResourceManagerActorFactoryImpl(akka.actor.ActorSystem actorSystem)
public akka.actor.ActorRef createSelfActorForMesosResourceManagerDriver(MesosResourceManagerDriver self)
MesosResourceManagerActorFactory
createSelfActorForMesosResourceManagerDriver
in interface MesosResourceManagerActorFactory
public akka.actor.ActorRef createConnectionMonitor(Configuration flinkConfig)
MesosResourceManagerActorFactory
createConnectionMonitor
in interface MesosResourceManagerActorFactory
public akka.actor.ActorRef createTaskMonitor(Configuration flinkConfig, akka.actor.ActorRef resourceManagerActor, org.apache.mesos.SchedulerDriver schedulerDriver)
MesosResourceManagerActorFactory
createTaskMonitor
in interface MesosResourceManagerActorFactory
public akka.actor.ActorRef createLaunchCoordinator(Configuration flinkConfig, akka.actor.ActorRef resourceManagerActor, org.apache.mesos.SchedulerDriver schedulerDriver, TaskSchedulerBuilder optimizer)
MesosResourceManagerActorFactory
createLaunchCoordinator
in interface MesosResourceManagerActorFactory
public akka.actor.ActorRef createReconciliationCoordinator(Configuration flinkConfig, org.apache.mesos.SchedulerDriver schedulerDriver)
MesosResourceManagerActorFactory
createReconciliationCoordinator
in interface MesosResourceManagerActorFactory
public CompletableFuture<Boolean> stopActor(@Nullable akka.actor.ActorRef actorRef, scala.concurrent.duration.FiniteDuration timeout)
MesosResourceManagerActorFactory
stopActor
in interface MesosResourceManagerActorFactory
actorRef
- specifying the actor to shut downtimeout
- for the graceful shut downtrue
iff. the actor could be stopped gracefully
or actorRef
was null
.Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.