org.apache.flink.api.java

Class ScalaShellEnvironment

java.lang.Object

org.apache.flink.api.java.ExecutionEnvironment

org.apache.flink.api.java.ScalaShellEnvironment

@Internal
public class ScalaShellEnvironment
extends ExecutionEnvironment

Special version of ExecutionEnvironment 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.

Field Summary

Fields inherited from class org.apache.flink.api.java.ExecutionEnvironment

lastJobExecutionResult, LOG

Constructor Summary

Constructors

Constructor and Description
ScalaShellEnvironment(Configuration configuration, org.apache.flink.api.scala.FlinkILoop flinkILoop, String... jarFiles)

Method Summary

Modifier and Type	Method and Description
static void	disableAllContextAndOtherEnvironments()
JobClient	executeAsync(String jobName) Triggers the program execution asynchronously.
static void	resetContextEnvironments()

Methods inherited from class org.apache.flink.api.java.ExecutionEnvironment

addDefaultKryoSerializer, addDefaultKryoSerializer, areExplicitEnvironmentsAllowed, clearJobListeners, configure, createCollectionsEnvironment, createInput, createInput, createLocalEnvironment, createLocalEnvironment, createLocalEnvironment, createLocalEnvironmentWithWebUI, createProgramPlan, createProgramPlan, createProgramPlan, createRemoteEnvironment, createRemoteEnvironment, createRemoteEnvironment, execute, execute, executeAsync, fromCollection, fromCollection, fromCollection, fromCollection, fromElements, fromElements, fromParallelCollection, fromParallelCollection, generateSequence, getConfig, getConfiguration, getDefaultLocalParallelism, getExecutionEnvironment, getExecutionPlan, getExecutorServiceLoader, getJobListeners, getLastJobExecutionResult, getNumberOfExecutionRetries, getParallelism, getRestartStrategy, getUserCodeClassLoader, initializeContextEnvironment, readCsvFile, readFile, readFileOfPrimitives, readFileOfPrimitives, readTextFile, readTextFile, readTextFileWithValue, readTextFileWithValue, registerCachedFile, registerCachedFile, registerCachedFilesWithPlan, registerJobListener, registerType, registerTypeWithKryoSerializer, registerTypeWithKryoSerializer, resetContextEnvironment, setDefaultLocalParallelism, setNumberOfExecutionRetries, setParallelism, setRestartStrategy

Methods inherited from class java.lang.Object

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

Constructor Detail

ScalaShellEnvironment

public ScalaShellEnvironment(Configuration configuration,
                             org.apache.flink.api.scala.FlinkILoop flinkILoop,
                             String... jarFiles)

Method Detail

executeAsync

public JobClient executeAsync(String jobName)
                       throws Exception

Description copied from class: ExecutionEnvironment

Triggers the program execution asynchronously. The environment will execute all parts of the program that have resulted in a "sink" operation. Sink operations are for example printing results (DataSet.print(), writing results (e.g. DataSet.writeAsText(String), DataSet.write(org.apache.flink.api.common.io.FileOutputFormat, String), or other generic data sinks created with DataSet.output(org.apache.flink.api.common.io.OutputFormat).

The program execution will be logged and displayed with the given job name.

Overrides:

executeAsync in class ExecutionEnvironment

Returns:

A JobClient that can be used to communicate with the submitted job, completed on submission succeeded.

Throws:

Exception - Thrown, if the program submission fails.

disableAllContextAndOtherEnvironments

public static void disableAllContextAndOtherEnvironments()

resetContextEnvironments

public static void resetContextEnvironments()