public class FlinkILoop extends ILoopCompat
scala.tools.nsc.interpreter.ILoop.ILoopInterpreter, scala.tools.nsc.interpreter.ILoop.IMainOps<T extends scala.tools.nsc.interpreter.IMain>, scala.tools.nsc.interpreter.ILoop.paste$
scala.tools.nsc.interpreter.LoopCommands.LineCmd, scala.tools.nsc.interpreter.LoopCommands.LoopCommand, scala.tools.nsc.interpreter.LoopCommands.LoopCommand$, scala.tools.nsc.interpreter.LoopCommands.NullaryCmd, scala.tools.nsc.interpreter.LoopCommands.Result, scala.tools.nsc.interpreter.LoopCommands.Result$, scala.tools.nsc.interpreter.LoopCommands.VarArgsCmd
Constructor and Description |
---|
FlinkILoop(String host,
int port,
Configuration clientConfig,
BufferedReader in0,
PrintWriter out) |
FlinkILoop(String host,
int port,
Configuration clientConfig,
scala.Option<String[]> externalJars) |
FlinkILoop(String host,
int port,
Configuration clientConfig,
scala.Option<String[]> externalJars,
BufferedReader in0,
PrintWriter out) |
FlinkILoop(String host,
int port,
Configuration clientConfig,
scala.Option<String[]> externalJars,
scala.Option<BufferedReader> in0,
PrintWriter out0) |
Modifier and Type | Method and Description |
---|---|
Configuration |
clientConfig() |
void |
createInterpreter() |
scala.Option<String[]> |
externalJars() |
String[] |
getExternalJars() |
String |
host() |
int |
port() |
void |
printWelcome()
custom welcome message
|
ExecutionEnvironment |
scalaBenv() |
StreamExecutionEnvironment |
scalaSenv() |
File |
writeFilesToDisk()
Packages the compiled classes of the current shell session into a Jar file for execution
on a Flink cluster.
|
prompt
addClasspath, addedClasspath_$eq, addedClasspath, addReplay, addThunk, asyncEcho, asyncMessage, awaitInitialized, chooseReader, closeInterpreter, command, commands, createAsyncListener, echo, echoAndRefresh, echoCommandMessage, echoNoNL, enablePowerMode, helpCommand, history, historyCommand, in_$eq, in, initializedCallback, interpretAllFrom, interpreter_$eq, interpreter, interpretStartingWith, intp_$eq, intp, isAsync, loadCommand, loadFiles, loop, LoopCommand, loopToInterpreter, main, newJavap, originalClassLoader, out, pasteCommand, postInitialization, postInitThunks, power, powerCmd, powerCommands, process, process, replay, replayCommands, replayCommandStack_$eq, replayCommandStack, replayQuestionMessage, reset, resetCommand, Result, run, run, run$default$2, runForTranscript, runThunks, savingReader, savingReplayStack, scala$tools$nsc$interpreter$ILoop$$addToolsJarToLoader, scala$tools$nsc$interpreter$ILoop$$deeply$1, scala$tools$nsc$interpreter$ILoop$$failMsg$1, scala$tools$nsc$interpreter$ILoop$$implicitsCommand, scala$tools$nsc$interpreter$ILoop$$importsCommand, scala$tools$nsc$interpreter$ILoop$$jarAt$1, scala$tools$nsc$interpreter$ILoop$$javapCommand, scala$tools$nsc$interpreter$ILoop$$phaseCommand, scala$tools$nsc$interpreter$ILoop$$readWhile, scala$tools$nsc$interpreter$ILoop$$typeCommand, scala$tools$nsc$interpreter$ILoop$$warningsCommand, scala$tools$nsc$interpreter$ILoopInit$_setter_$scala$tools$nsc$interpreter$ILoopInit$$initCompilerCondition_$eq, scala$tools$nsc$interpreter$ILoopInit$_setter_$scala$tools$nsc$interpreter$ILoopInit$$initLock_$eq, scala$tools$nsc$interpreter$ILoopInit$_setter_$scala$tools$nsc$interpreter$ILoopInit$$initLoopCondition_$eq, scala$tools$nsc$interpreter$ILoopInit$_setter_$scala$tools$nsc$interpreter$ILoopInit$$initStart_$eq, scala$tools$nsc$interpreter$ILoopInit$$initCompilerCondition, scala$tools$nsc$interpreter$ILoopInit$$initError_$eq, scala$tools$nsc$interpreter$ILoopInit$$initError, scala$tools$nsc$interpreter$ILoopInit$$initIsComplete_$eq, scala$tools$nsc$interpreter$ILoopInit$$initIsComplete, scala$tools$nsc$interpreter$ILoopInit$$initLock, scala$tools$nsc$interpreter$ILoopInit$$initLoopCondition, scala$tools$nsc$interpreter$ILoopInit$$initStart, scala$tools$nsc$interpreter$ILoopInit$$pendingThunks_$eq, scala$tools$nsc$interpreter$ILoopInit$$pendingThunks, searchHistory, setPrompt, settings_$eq, settings, shCommand, stabilizeIMain, standardCommands, verbosity, withFile
public FlinkILoop(String host, int port, Configuration clientConfig, scala.Option<String[]> externalJars, scala.Option<BufferedReader> in0, PrintWriter out0)
public FlinkILoop(String host, int port, Configuration clientConfig, scala.Option<String[]> externalJars, BufferedReader in0, PrintWriter out)
public FlinkILoop(String host, int port, Configuration clientConfig, scala.Option<String[]> externalJars)
public FlinkILoop(String host, int port, Configuration clientConfig, BufferedReader in0, PrintWriter out)
public String host()
public int port()
public Configuration clientConfig()
public scala.Option<String[]> externalJars()
public ExecutionEnvironment scalaBenv()
public StreamExecutionEnvironment scalaSenv()
public void createInterpreter()
createInterpreter
in class scala.tools.nsc.interpreter.ILoop
public File writeFilesToDisk()
public void printWelcome()
printWelcome
in interface scala.tools.nsc.interpreter.ILoopInit
printWelcome
in class scala.tools.nsc.interpreter.ILoop
public String[] getExternalJars()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.