public class BootstrapTools extends Object
Modifier and Type | Method and Description |
---|---|
static Configuration |
generateTaskManagerConfiguration(Configuration baseConfig,
String jobManagerHostname,
int jobManagerPort,
int numSlots,
scala.concurrent.duration.FiniteDuration registrationTimeout)
Generate a task manager configuration.
|
static String |
getTaskManagerShellCommand(Configuration flinkConfig,
ContaineredTaskManagerParameters tmParams,
String configDirectory,
String logDirectory,
boolean hasLogback,
boolean hasLog4j,
Class<?> mainClass)
Generates the shell command to start a task manager.
|
static akka.actor.ActorSystem |
startActorSystem(Configuration configuration,
String listeningAddress,
int listeningPort,
org.slf4j.Logger logger)
Starts an Actor System at a specific port.
|
static akka.actor.ActorSystem |
startActorSystem(Configuration configuration,
String listeningAddress,
String portRangeDefinition,
org.slf4j.Logger logger)
Starts an ActorSystem with the given configuration listening at the address/ports.
|
static WebMonitor |
startWebMonitorIfConfigured(Configuration config,
akka.actor.ActorSystem actorSystem,
akka.actor.ActorRef jobManager,
org.slf4j.Logger logger)
Starts the web frontend.
|
static void |
substituteDeprecatedConfigKey(Configuration config,
String deprecated,
String designated)
Sets the value of a new config key to the value of a deprecated config key.
|
static void |
substituteDeprecatedConfigPrefix(Configuration config,
String deprecatedPrefix,
String designatedPrefix)
Sets the value of of a new config key to the value of a deprecated config key.
|
static void |
writeConfiguration(Configuration cfg,
File file)
Writes a Flink YAML config file from a Flink Configuration object.
|
public static akka.actor.ActorSystem startActorSystem(Configuration configuration, String listeningAddress, String portRangeDefinition, org.slf4j.Logger logger) throws Exception
configuration
- The Flink configurationlisteningAddress
- The address to listen at.portRangeDefinition
- The port range to choose a port from.logger
- The logger to output log information.Exception
public static akka.actor.ActorSystem startActorSystem(Configuration configuration, String listeningAddress, int listeningPort, org.slf4j.Logger logger) throws Exception
configuration
- The Flink configuration.listeningAddress
- The address to listen at.listeningPort
- The port to listen at.logger
- the logger to output log information.Exception
public static WebMonitor startWebMonitorIfConfigured(Configuration config, akka.actor.ActorSystem actorSystem, akka.actor.ActorRef jobManager, org.slf4j.Logger logger) throws Exception
config
- The Flink config.actorSystem
- The ActorSystem to start the web frontend in.logger
- Logger for log outputException
public static Configuration generateTaskManagerConfiguration(Configuration baseConfig, String jobManagerHostname, int jobManagerPort, int numSlots, scala.concurrent.duration.FiniteDuration registrationTimeout)
baseConfig
- Config to start from.jobManagerHostname
- Job manager host name.jobManagerPort
- Port of the job manager.numSlots
- Number of slots to configure.registrationTimeout
- Timeout for registrationpublic static void writeConfiguration(Configuration cfg, File file) throws IOException
cfg
- The Flink configfile
- The File to write toIOException
public static void substituteDeprecatedConfigKey(Configuration config, String deprecated, String designated)
config
- Config to writedeprecated
- The old config keydesignated
- The new config keypublic static void substituteDeprecatedConfigPrefix(Configuration config, String deprecatedPrefix, String designatedPrefix)
config
- Config to writedeprecatedPrefix
- Old prefix of keydesignatedPrefix
- New prefix of keypublic static String getTaskManagerShellCommand(Configuration flinkConfig, ContaineredTaskManagerParameters tmParams, String configDirectory, String logDirectory, boolean hasLogback, boolean hasLog4j, Class<?> mainClass)
flinkConfig
- The Flink configuration.tmParams
- Paramaters for the task manager.configDirectory
- The configuration directory for the flink-conf.yamllogDirectory
- The log directory.hasLogback
- Uses logback?hasLog4j
- Uses log4j?mainClass
- The main class to start with.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.