public class LaunchCoordinator$ extends Object
Modifier and Type | Field and Description |
---|---|
static LaunchCoordinator$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
LaunchCoordinator$() |
Modifier and Type | Method and Description |
---|---|
<T extends LaunchCoordinator> |
createActorProps(Class<T> actorClass,
akka.actor.ActorRef manager,
Configuration flinkConfig,
org.apache.mesos.SchedulerDriver schedulerDriver,
TaskSchedulerBuilder optimizerBuilder)
Get the configuration properties for the launch coordinator.
|
scala.concurrent.duration.FiniteDuration |
GATHER_DURATION() |
public static final LaunchCoordinator$ MODULE$
public scala.concurrent.duration.FiniteDuration GATHER_DURATION()
public <T extends LaunchCoordinator> akka.actor.Props createActorProps(Class<T> actorClass, akka.actor.ActorRef manager, Configuration flinkConfig, org.apache.mesos.SchedulerDriver schedulerDriver, TaskSchedulerBuilder optimizerBuilder)
actorClass
- the launch coordinator actor class.flinkConfig
- the Flink configuration.schedulerDriver
- the Mesos scheduler driver.manager
- (undocumented)optimizerBuilder
- (undocumented)Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.