Package | Description |
---|---|
org.apache.flink.yarn | |
org.apache.flink.yarn.cli |
Modifier and Type | Method and Description |
---|---|
protected YarnClusterClient |
AbstractYarnClusterDescriptor.createYarnClusterClient(AbstractYarnClusterDescriptor descriptor,
int numberTaskManagers,
int slotsPerTaskManager,
org.apache.hadoop.yarn.client.api.YarnClient yarnClient,
org.apache.hadoop.yarn.api.records.ApplicationReport report,
Configuration flinkConfiguration,
boolean perJobCluster)
Creates a YarnClusterClient; may be overriden in tests.
|
protected YarnClusterClient |
AbstractYarnClusterDescriptor.deployInternal(ClusterSpecification clusterSpecification,
String yarnClusterEntrypoint,
JobGraph jobGraph)
This method will block until the ApplicationMaster/JobManager have been
deployed on YARN.
|
YarnClusterClient |
YarnClusterDescriptor.deployJobCluster(ClusterSpecification clusterSpecification,
JobGraph jobGraph) |
YarnClusterClient |
AbstractYarnClusterDescriptor.deployJobCluster(ClusterSpecification clusterSpecification,
JobGraph jobGraph) |
YarnClusterClient |
AbstractYarnClusterDescriptor.deploySessionCluster(ClusterSpecification clusterSpecification) |
YarnClusterClient |
AbstractYarnClusterDescriptor.retrieve(String applicationID) |
Modifier and Type | Method and Description |
---|---|
YarnClusterClient |
FlinkYarnSessionCli.createCluster(String applicationName,
org.apache.commons.cli.CommandLine cmdLine,
Configuration config,
String configurationDirectory,
List<URL> userJarFiles) |
YarnClusterClient |
FlinkYarnSessionCli.retrieveCluster(org.apache.commons.cli.CommandLine cmdLine,
Configuration config,
String configurationDirectory) |
Modifier and Type | Method and Description |
---|---|
static void |
FlinkYarnSessionCli.runInteractiveCli(YarnClusterClient yarnCluster,
boolean readConsoleInput) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.