org.apache.flink.client.program

Class ContextEnvironmentFactory

java.lang.Object

org.apache.flink.client.program.ContextEnvironmentFactory

All Implemented Interfaces:

org.apache.flink.api.java.ExecutionEnvironmentFactory

public class ContextEnvironmentFactory
extends Object
implements org.apache.flink.api.java.ExecutionEnvironmentFactory

The factory that instantiates the environment to be used when running jobs that are submitted through a pre-configured client connection. This happens for example when a job is submitted from the command line.

Constructor Summary

Constructors

Constructor and Description
ContextEnvironmentFactory(org.apache.flink.core.execution.PipelineExecutorServiceLoader executorServiceLoader, org.apache.flink.configuration.Configuration configuration, ClassLoader userCodeClassLoader)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.api.java.ExecutionEnvironment	createExecutionEnvironment()

Methods inherited from class java.lang.Object

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

Constructor Detail

ContextEnvironmentFactory

public ContextEnvironmentFactory(org.apache.flink.core.execution.PipelineExecutorServiceLoader executorServiceLoader,
                                 org.apache.flink.configuration.Configuration configuration,
                                 ClassLoader userCodeClassLoader)

Method Detail

createExecutionEnvironment

public org.apache.flink.api.java.ExecutionEnvironment createExecutionEnvironment()

Specified by:

createExecutionEnvironment in interface org.apache.flink.api.java.ExecutionEnvironmentFactory