org.apache.flink.api.scala

Class FlinkShell

java.lang.Object

org.apache.flink.api.scala.FlinkShell

public class FlinkShell
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FlinkShell.ExecutionMode$

Constructor Summary

Constructors

Constructor and Description
FlinkShell()

Method Summary

Modifier and Type	Method and Description
static scala.Option<BufferedReader>	bufferedReader()
static void	main(String[] args)
static void	startShell(String userHost, int userPort, scala.Enumeration.Value executionMode, scala.Option<String[]> externalJars)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlinkShell

public FlinkShell()

Method Detail

bufferedReader

public static scala.Option<BufferedReader> bufferedReader()

main

public static void main(String[] args)

startShell

public static void startShell(String userHost,
                              int userPort,
                              scala.Enumeration.Value executionMode,
                              scala.Option<String[]> externalJars)