public class FlinkShell extends Object
Modifier and Type | Class and Description |
---|---|
static class |
FlinkShell.Config
Configuration object
|
static class |
FlinkShell.Config$ |
static class |
FlinkShell.ExecutionMode$ |
static class |
FlinkShell.YarnConfig
YARN configuration object
|
static class |
FlinkShell.YarnConfig$ |
Constructor and Description |
---|
FlinkShell() |
Modifier and Type | Method and Description |
---|---|
static scala.Option<BufferedReader> |
bufferedReader()
Buffered reader to substitute input in test
|
static scala.Tuple3<String,Object,scala.Some<scala.util.Right<scala.runtime.Nothing$,ClusterClient>>> |
deployNewYarnCluster(FlinkShell.YarnConfig yarnConfig) |
static FlinkShell.YarnConfig |
ensureYarnConfig(FlinkShell.Config config) |
static scala.Tuple3<String,Object,scala.Option<scala.util.Either<FlinkMiniCluster,ClusterClient>>> |
fetchConnectionInfo(FlinkShell.Config config) |
static scala.Tuple3<String,Object,scala.None$> |
fetchDeployedYarnClusterInfo() |
static void |
main(String[] args) |
static void |
startShell(FlinkShell.Config config) |
public static scala.Option<BufferedReader> bufferedReader()
public static void main(String[] args)
public static scala.Tuple3<String,Object,scala.Option<scala.util.Either<FlinkMiniCluster,ClusterClient>>> fetchConnectionInfo(FlinkShell.Config config)
public static void startShell(FlinkShell.Config config)
public static scala.Tuple3<String,Object,scala.Some<scala.util.Right<scala.runtime.Nothing$,ClusterClient>>> deployNewYarnCluster(FlinkShell.YarnConfig yarnConfig)
public static scala.Tuple3<String,Object,scala.None$> fetchDeployedYarnClusterInfo()
public static FlinkShell.YarnConfig ensureYarnConfig(FlinkShell.Config config)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.