org.apache.flink.api.java

类 ScalaShellEnvironment

java.lang.Object

org.apache.flink.api.java.ExecutionEnvironment

org.apache.flink.api.java.ScalaShellEnvironment

@Internal
public class ScalaShellEnvironment
extends org.apache.flink.api.java.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.

字段概要

从类继承的字段 org.apache.flink.api.java.ExecutionEnvironment

lastJobExecutionResult, LOG

构造器概要

构造器

构造器和说明
ScalaShellEnvironment(org.apache.flink.configuration.Configuration configuration, org.apache.flink.api.scala.FlinkILoop flinkILoop, String... jarFiles)

方法概要

限定符和类型	方法和说明
static void	disableAllContextAndOtherEnvironments()
org.apache.flink.api.common.JobExecutionResult	execute(String jobName)
static void	resetContextEnvironments()

从类继承的方法 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, executeAsync, executeAsync, fromCollection, fromCollection, fromCollection, fromCollection, fromElements, fromElements, fromParallelCollection, fromParallelCollection, generateSequence, getConfig, getConfiguration, getDefaultLocalParallelism, getExecutionEnvironment, getExecutionPlan, getExecutorServiceLoader, 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

从类继承的方法 java.lang.Object

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

构造器详细资料

ScalaShellEnvironment

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

方法详细资料

execute

public org.apache.flink.api.common.JobExecutionResult execute(String jobName)
                                                       throws Exception

覆盖:

execute 在类中 org.apache.flink.api.java.ExecutionEnvironment

抛出:

Exception

disableAllContextAndOtherEnvironments

public static void disableAllContextAndOtherEnvironments()

resetContextEnvironments

public static void resetContextEnvironments()