Package | Description |
---|---|
org.apache.flink.client | |
org.apache.flink.yarn |
Modifier and Type | Method and Description |
---|---|
AbstractFlinkYarnClient |
FlinkYarnSessionCli.createFlinkYarnClient(org.apache.commons.cli.CommandLine cmd)
Creates a new Yarn Client.
|
static AbstractFlinkYarnClient |
FlinkYarnSessionCli.getFlinkYarnClient() |
Modifier and Type | Class and Description |
---|---|
class |
FlinkYarnClient
Default implementation of
FlinkYarnClientBase which starts an ApplicationMaster . |
class |
FlinkYarnClientBase
All classes in this package contain code taken from
https://github.com/apache/hadoop-common/blob/trunk/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/main/java/org/apache/hadoop/yarn/applications/distributedshell/Client.java?source=cc
and
https://github.com/hortonworks/simple-yarn-app
and
https://github.com/yahoo/storm-yarn/blob/master/src/main/java/com/yahoo/storm/yarn/StormOnYarn.java
The Flink jar is uploaded to HDFS by this client.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.