Package | Description |
---|---|
org.apache.flink.client | |
org.apache.flink.runtime.yarn | |
org.apache.flink.yarn |
Modifier and Type | Method and Description |
---|---|
static void |
FlinkYarnSessionCli.runInteractiveCli(AbstractFlinkYarnCluster yarnCluster) |
Modifier and Type | Method and Description |
---|---|
abstract AbstractFlinkYarnCluster |
AbstractFlinkYarnClient.deploy()
Trigger the deployment to YARN.
|
Modifier and Type | Class and Description |
---|---|
class |
FlinkYarnCluster
Java representation of a running Flink cluster within YARN.
|
Modifier and Type | Method and Description |
---|---|
AbstractFlinkYarnCluster |
FlinkYarnClientBase.deploy() |
protected AbstractFlinkYarnCluster |
FlinkYarnClientBase.deployInternal()
This method will block until the ApplicationMaster/JobManager have been
deployed on YARN.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.