public class ConnectionMonitor$ extends Object
Modifier and Type | Field and Description |
---|---|
static ConnectionMonitor$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
ConnectionMonitor$() |
Modifier and Type | Method and Description |
---|---|
scala.concurrent.duration.FiniteDuration |
CONNECT_RETRY_RATE() |
<T extends ConnectionMonitor> |
createActorProps(Class<T> actorClass,
Configuration flinkConfig)
Creates the properties for the ConnectionMonitor actor.
|
public static final ConnectionMonitor$ MODULE$
public scala.concurrent.duration.FiniteDuration CONNECT_RETRY_RATE()
public <T extends ConnectionMonitor> akka.actor.Props createActorProps(Class<T> actorClass, Configuration flinkConfig)
actorClass
- the connection monitor actor classflinkConfig
- the Flink configuration.Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.