public class TaskMonitor$ extends Object
Modifier and Type | Field and Description |
---|---|
static TaskMonitor$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
TaskMonitor$() |
Modifier and Type | Method and Description |
---|---|
<T extends TaskMonitor> |
createActorProps(Class<T> actorClass,
Configuration flinkConfig,
org.apache.mesos.SchedulerDriver schedulerDriver,
TaskMonitor.TaskGoalState goalState)
Creates the properties for the TaskMonitor actor.
|
scala.concurrent.duration.FiniteDuration |
LAUNCH_TIMEOUT() |
scala.concurrent.duration.FiniteDuration |
RETRY_INTERVAL() |
public static final TaskMonitor$ MODULE$
public scala.concurrent.duration.FiniteDuration RETRY_INTERVAL()
public scala.concurrent.duration.FiniteDuration LAUNCH_TIMEOUT()
public <T extends TaskMonitor> akka.actor.Props createActorProps(Class<T> actorClass, Configuration flinkConfig, org.apache.mesos.SchedulerDriver schedulerDriver, TaskMonitor.TaskGoalState goalState)
actorClass
- the task monitor actor classflinkConfig
- the Flink configurationschedulerDriver
- the Mesos scheduler drivergoalState
- the task's goal stateCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.