@Deprecated public interface MesosResourceManagerActorFactory
Modifier and Type | Method and Description |
---|---|
akka.actor.ActorRef |
createConnectionMonitor(Configuration flinkConfig)
Deprecated.
Create actor for the connection monitor.
|
akka.actor.ActorRef |
createLaunchCoordinator(Configuration flinkConfig,
akka.actor.ActorRef resourceManagerActor,
org.apache.mesos.SchedulerDriver schedulerDriver,
TaskSchedulerBuilder optimizer)
Deprecated.
Create actor for the launch coordinator.
|
akka.actor.ActorRef |
createReconciliationCoordinator(Configuration flinkConfig,
org.apache.mesos.SchedulerDriver schedulerDriver)
Deprecated.
Create actor for the reconciliation coordinator.
|
akka.actor.ActorRef |
createSelfActorForMesosResourceManagerDriver(MesosResourceManagerDriver self)
Deprecated.
Create self actor for mesos resource manager.
|
akka.actor.ActorRef |
createTaskMonitor(Configuration flinkConfig,
akka.actor.ActorRef resourceManagerActor,
org.apache.mesos.SchedulerDriver schedulerDriver)
Deprecated.
Create actor for the task monitor.
|
CompletableFuture<Boolean> |
stopActor(akka.actor.ActorRef actorRef,
scala.concurrent.duration.FiniteDuration timeout)
Deprecated.
Tries to shut down the given actor gracefully.
|
akka.actor.ActorRef createSelfActorForMesosResourceManagerDriver(MesosResourceManagerDriver self)
akka.actor.ActorRef createConnectionMonitor(Configuration flinkConfig)
akka.actor.ActorRef createTaskMonitor(Configuration flinkConfig, akka.actor.ActorRef resourceManagerActor, org.apache.mesos.SchedulerDriver schedulerDriver)
akka.actor.ActorRef createLaunchCoordinator(Configuration flinkConfig, akka.actor.ActorRef resourceManagerActor, org.apache.mesos.SchedulerDriver schedulerDriver, TaskSchedulerBuilder optimizer)
akka.actor.ActorRef createReconciliationCoordinator(Configuration flinkConfig, org.apache.mesos.SchedulerDriver schedulerDriver)
CompletableFuture<Boolean> stopActor(@Nullable akka.actor.ActorRef actorRef, scala.concurrent.duration.FiniteDuration timeout)
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–2022 The Apache Software Foundation. All rights reserved.