org.apache.flink.datastream.impl

Class ExecutionEnvironmentImpl

java.lang.Object

org.apache.flink.datastream.impl.ExecutionEnvironmentImpl

All Implemented Interfaces:

ExecutionEnvironment

Direct Known Subclasses:

ExecutionContextEnvironment

public class ExecutionEnvironmentImpl
extends Object
implements ExecutionEnvironment

The implementation of ExecutionEnvironment.

IMPORTANT: Even though this is not part of public API, ExecutionEnvironment will get this class instance through reflection, so we must ensure that the package path, class name and the signature of newInstance() does not change.

Method Summary

Modifier and Type	Method and Description
void	addOperator(Transformation<?> transformation)
void	execute(String jobName) Execute and submit the job attached to this environment.
<OUT> NonKeyedPartitionStream<OUT>	fromSource(Source<OUT> source, String sourceName)
CheckpointConfig	getCheckpointCfg()
Configuration	getConfiguration()
ExecutionConfig	getExecutionConfig()
RuntimeExecutionMode	getExecutionMode() Get the execution mode of this environment.
int	getParallelism()
StreamGraph	getStreamGraph() Get StreamGraph and clear all transformations.
List<Transformation<?>>	getTransformations()
protected static void	initializeContextEnvironment(ExecutionEnvironmentFactory ctx)
static ExecutionEnvironment	newInstance() Create and return an instance of ExecutionEnvironment.
protected static void	resetContextEnvironment()
ExecutionEnvironment	setExecutionMode(RuntimeExecutionMode runtimeMode) Set the execution mode for this environment.
void	setParallelism(int parallelism)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.datastream.api.ExecutionEnvironment

getInstance

Method Detail

newInstance

public static ExecutionEnvironment newInstance()

Create and return an instance of ExecutionEnvironment.

IMPORTANT: The method is only expected to be called by ExecutionEnvironment via reflection, so we must ensure that the package path, class name and the signature of this method does not change.

execute

public void execute(String jobName)
             throws Exception

Description copied from interface: ExecutionEnvironment

Execute and submit the job attached to this environment.

Specified by:

execute in interface ExecutionEnvironment

Throws:

Exception

getExecutionMode

public RuntimeExecutionMode getExecutionMode()

Description copied from interface: ExecutionEnvironment

Get the execution mode of this environment.

Specified by:

getExecutionMode in interface ExecutionEnvironment

setExecutionMode

public ExecutionEnvironment setExecutionMode(RuntimeExecutionMode runtimeMode)

Description copied from interface: ExecutionEnvironment

Set the execution mode for this environment.

Specified by:

setExecutionMode in interface ExecutionEnvironment

initializeContextEnvironment

protected static void initializeContextEnvironment(ExecutionEnvironmentFactory ctx)

resetContextEnvironment

protected static void resetContextEnvironment()

fromSource

public <OUT> NonKeyedPartitionStream<OUT> fromSource(Source<OUT> source,
                                                     String sourceName)

Specified by:

fromSource in interface ExecutionEnvironment

getConfiguration

public Configuration getConfiguration()

getExecutionConfig

public ExecutionConfig getExecutionConfig()

getParallelism

public int getParallelism()

getTransformations

public List<Transformation<?>> getTransformations()

setParallelism

public void setParallelism(int parallelism)

getCheckpointCfg

public CheckpointConfig getCheckpointCfg()

addOperator

public void addOperator(Transformation<?> transformation)

getStreamGraph

public StreamGraph getStreamGraph()

Get StreamGraph and clear all transformations.