Package | Description |
---|---|
org.apache.flink.api.scala |
Modifier and Type | Method and Description |
---|---|
static FlinkShell.YarnConfig |
FlinkShell.ensureYarnConfig(FlinkShell.Config config) |
FlinkShell.YarnConfig |
FlinkShell$.ensureYarnConfig(FlinkShell.Config config) |
Modifier and Type | Method and Description |
---|---|
scala.Option<FlinkShell.YarnConfig> |
FlinkShell.Config.yarnConfig() |
Modifier and Type | Method and Description |
---|---|
static scala.Tuple3<String,Object,scala.Some<scala.util.Right<scala.runtime.Nothing$,ClusterClient>>> |
FlinkShell.deployNewYarnCluster(FlinkShell.YarnConfig yarnConfig) |
scala.Tuple3<String,Object,scala.Some<scala.util.Right<scala.runtime.Nothing$,ClusterClient>>> |
FlinkShell$.deployNewYarnCluster(FlinkShell.YarnConfig yarnConfig) |
Constructor and Description |
---|
Config(scala.Option<String> host,
scala.Option<Object> port,
scala.Option<String[]> externalJars,
scala.Enumeration.Value executionMode,
scala.Option<FlinkShell.YarnConfig> yarnConfig,
scala.Option<String> configDir) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.