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