org.apache.flink.datastream.impl

类 ExecutionEnvironmentImpl

java.lang.Object

org.apache.flink.datastream.impl.ExecutionEnvironmentImpl

所有已实现的接口:

org.apache.flink.datastream.api.ExecutionEnvironment

直接已知子类:

ExecutionContextEnvironment

public class ExecutionEnvironmentImpl
extends Object
implements org.apache.flink.datastream.api.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.

方法概要

限定符和类型	方法和说明
void	addOperator(org.apache.flink.api.dag.Transformation<?> transformation)
void	execute(String jobName)
<OUT> org.apache.flink.datastream.api.stream.NonKeyedPartitionStream<OUT>	fromSource(org.apache.flink.api.connector.dsv2.Source<OUT> source, String sourceName)
org.apache.flink.streaming.api.environment.CheckpointConfig	getCheckpointCfg()
org.apache.flink.configuration.Configuration	getConfiguration()
org.apache.flink.api.common.ExecutionConfig	getExecutionConfig()
org.apache.flink.api.common.RuntimeExecutionMode	getExecutionMode()
int	getParallelism()
org.apache.flink.streaming.api.graph.StreamGraph	getStreamGraph() Get StreamGraph and clear all transformations.
List<org.apache.flink.api.dag.Transformation<?>>	getTransformations()
protected static void	initializeContextEnvironment(ExecutionEnvironmentFactory ctx)
static org.apache.flink.datastream.api.ExecutionEnvironment	newInstance() Create and return an instance of ExecutionEnvironment.
protected static void	resetContextEnvironment()
org.apache.flink.datastream.api.ExecutionEnvironment	setExecutionMode(org.apache.flink.api.common.RuntimeExecutionMode runtimeMode)
void	setParallelism(int parallelism)

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

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

从接口继承的方法 org.apache.flink.datastream.api.ExecutionEnvironment

getInstance

方法详细资料

newInstance

public static org.apache.flink.datastream.api.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

指定者:

execute 在接口中 org.apache.flink.datastream.api.ExecutionEnvironment

抛出:

Exception

getExecutionMode

public org.apache.flink.api.common.RuntimeExecutionMode getExecutionMode()

指定者:

getExecutionMode 在接口中 org.apache.flink.datastream.api.ExecutionEnvironment

setExecutionMode

public org.apache.flink.datastream.api.ExecutionEnvironment setExecutionMode(org.apache.flink.api.common.RuntimeExecutionMode runtimeMode)

指定者:

setExecutionMode 在接口中 org.apache.flink.datastream.api.ExecutionEnvironment

initializeContextEnvironment

protected static void initializeContextEnvironment(ExecutionEnvironmentFactory ctx)

resetContextEnvironment

protected static void resetContextEnvironment()

fromSource

public <OUT> org.apache.flink.datastream.api.stream.NonKeyedPartitionStream<OUT> fromSource(org.apache.flink.api.connector.dsv2.Source<OUT> source,
                                                                                            String sourceName)

指定者:

fromSource 在接口中 org.apache.flink.datastream.api.ExecutionEnvironment

getConfiguration

public org.apache.flink.configuration.Configuration getConfiguration()

getExecutionConfig

public org.apache.flink.api.common.ExecutionConfig getExecutionConfig()

getParallelism

public int getParallelism()

getTransformations

public List<org.apache.flink.api.dag.Transformation<?>> getTransformations()

setParallelism

public void setParallelism(int parallelism)

getCheckpointCfg

public org.apache.flink.streaming.api.environment.CheckpointConfig getCheckpointCfg()

addOperator

public void addOperator(org.apache.flink.api.dag.Transformation<?> transformation)

getStreamGraph

public org.apache.flink.streaming.api.graph.StreamGraph getStreamGraph()

Get StreamGraph and clear all transformations.