public class ScalaShellRemoteEnvironment extends RemoteEnvironment
RemoteEnvironment
that has a reference
to a FlinkILoop
. When execute is called this will
use the reference of the ILoop to write the compiled classes of the current session to
a Jar file and submit these with the program.host, port
jobID, lastJobExecutionResult, LOG, sessionTimeout
Constructor and Description |
---|
ScalaShellRemoteEnvironment(String host,
int port,
FlinkILoop flinkILoop,
String... jarFiles)
Creates new ScalaShellRemoteEnvironment that has a reference to the FlinkILoop
|
Modifier and Type | Method and Description |
---|---|
static void |
disableAllContextAndOtherEnvironments() |
JobExecutionResult |
execute(String jobName)
compiles jars from files in the shell virtual directory on the fly, sends and executes it in the remote environment
|
static void |
resetContextEnvironments() |
dispose, getExecutionPlan, startNewSession, toString
addDefaultKryoSerializer, addDefaultKryoSerializer, areExplicitEnvironmentsAllowed, createCollectionsEnvironment, createHadoopInput, createHadoopInput, createInput, createInput, createLocalEnvironment, createLocalEnvironment, createLocalEnvironment, createProgramPlan, createProgramPlan, createProgramPlan, createRemoteEnvironment, createRemoteEnvironment, createRemoteEnvironment, execute, fromCollection, fromCollection, fromCollection, fromCollection, fromElements, fromParallelCollection, fromParallelCollection, generateSequence, getConfig, getExecutionEnvironment, getId, getIdString, getLastJobExecutionResult, getNumberOfExecutionRetries, getParallelism, getRestartStrategy, getSessionTimeout, initializeContextEnvironment, readCsvFile, readFile, readFileOfPrimitives, readFileOfPrimitives, readHadoopFile, readHadoopFile, readHadoopFile, readHadoopFile, readSequenceFile, readTextFile, readTextFile, readTextFileWithValue, readTextFileWithValue, registerCachedFile, registerCachedFile, registerCachedFilesWithPlan, registerType, registerTypeWithKryoSerializer, registerTypeWithKryoSerializer, resetContextEnvironment, setDefaultLocalParallelism, setNumberOfExecutionRetries, setParallelism, setRestartStrategy, setSessionTimeout
public ScalaShellRemoteEnvironment(String host, int port, FlinkILoop flinkILoop, String... jarFiles)
host
- The host name or address of the master (JobManager), where the program should be executed.port
- The port of the master (JobManager), where the program should be executed.flinkILoop
- The flink Iloop instance from which the ScalaShellRemoteEnvironment is called.public JobExecutionResult execute(String jobName) throws Exception
execute
in class RemoteEnvironment
jobName
- name of the job as stringException
public static void disableAllContextAndOtherEnvironments()
public static void resetContextEnvironments()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.