org.apache.flink.table.planner.utils

类 DummyStreamExecutionEnvironment

java.lang.Object

org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

org.apache.flink.table.planner.utils.DummyStreamExecutionEnvironment

public class DummyStreamExecutionEnvironment
extends org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

This is dummy StreamExecutionEnvironment, which holds a real StreamExecutionEnvironment, shares all configurations of the real environment, and disables all configuration setting methods.

When translating relational plan to execution plan in the Planner, the generated Transformations will be added into StreamExecutionEnvironment's buffer, and they will be cleared only when StreamExecutionEnvironment.execute() method is called. Each TableEnvironment instance holds an immutable StreamExecutionEnvironment instance. If there are multiple translations (not all for `execute`, e.g. `explain` and then `execute`) in one TableEnvironment instance, the transformation buffer is dirty, and execution result may be incorrect.

This dummy StreamExecutionEnvironment is only used for buffering the transformations generated in the planner. A new dummy StreamExecutionEnvironment instance should be created for each translation, and this could avoid dirty the transformation buffer of the real StreamExecutionEnvironment instance.

All set methods (e.g. `setXX`, `enableXX`, `disableXX`, etc) are disabled to prohibit changing configuration, all get methods (e.g. `getXX`, `isXX`, etc) will be delegated to the real StreamExecutionEnvironment. `execute`, `getStreamGraph`, `getExecutionPlan` methods are also disabled, while `addOperator` method is enabled to allow the planner to add the generated transformations to the dummy StreamExecutionEnvironment.

This class could be removed once the StreamTableSource interface and StreamTableSink interface are reworked.

NOTE: Please remove com.esotericsoftware.kryo item in the whitelist of checkCodeDependencies() method in test_table_shaded_dependencies.sh end-to-end test when this class is removed.

字段概要

从类继承的字段 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

cacheFile, checkpointCfg, config, configuration, DEFAULT_JOB_NAME, isChainingEnabled, transformations

构造器概要

构造器

构造器和说明
DummyStreamExecutionEnvironment(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment realExecEnv)

方法概要

限定符和类型	方法和说明
void	addDefaultKryoSerializer(Class<?> type, Class<? extends com.esotericsoftware.kryo.Serializer<?>> serializerClass)
<T extends com.esotericsoftware.kryo.Serializer<?> & Serializable> void	addDefaultKryoSerializer(Class<?> type, T serializer)
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment	disableOperatorChaining()
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment	enableCheckpointing()
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment	enableCheckpointing(long interval)
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment	enableCheckpointing(long interval, org.apache.flink.streaming.api.CheckpointingMode mode)
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment	enableCheckpointing(long interval, org.apache.flink.streaming.api.CheckpointingMode mode, boolean force)
org.apache.flink.api.common.JobExecutionResult	execute()
org.apache.flink.api.common.JobExecutionResult	execute(org.apache.flink.streaming.api.graph.StreamGraph streamGraph)
org.apache.flink.api.common.JobExecutionResult	execute(String jobName)
long	getBufferTimeout()
List<org.apache.flink.api.java.tuple.Tuple2<String,org.apache.flink.api.common.cache.DistributedCache.DistributedCacheEntry>>	getCachedFiles()
org.apache.flink.streaming.api.environment.CheckpointConfig	getCheckpointConfig()
org.apache.flink.streaming.api.CheckpointingMode	getCheckpointingMode()
long	getCheckpointInterval()
org.apache.flink.api.common.ExecutionConfig	getConfig()
org.apache.flink.configuration.ReadableConfig	getConfiguration()
String	getExecutionPlan()
int	getMaxParallelism()
int	getNumberOfExecutionRetries()
int	getParallelism()
org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration	getRestartStrategy()
org.apache.flink.runtime.state.StateBackend	getStateBackend()
org.apache.flink.streaming.api.graph.StreamGraph	getStreamGraph()
org.apache.flink.streaming.api.TimeCharacteristic	getStreamTimeCharacteristic()
boolean	isChainingEnabled()
boolean	isForceCheckpointing()
void	registerCachedFile(String filePath, String name)
void	registerCachedFile(String filePath, String name, boolean executable)
void	registerType(Class<?> type)
void	registerTypeWithKryoSerializer(Class<?> type, Class<? extends com.esotericsoftware.kryo.Serializer> serializerClass)
<T extends com.esotericsoftware.kryo.Serializer<?> & Serializable> void	registerTypeWithKryoSerializer(Class<?> type, T serializer)
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment	setBufferTimeout(long timeoutMillis)
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment	setMaxParallelism(int maxParallelism)
void	setNumberOfExecutionRetries(int numberOfExecutionRetries)
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment	setParallelism(int parallelism)
void	setRestartStrategy(org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration restartStrategyConfiguration)
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment	setStateBackend(org.apache.flink.runtime.state.StateBackend backend)
void	setStreamTimeCharacteristic(org.apache.flink.streaming.api.TimeCharacteristic characteristic)

从类继承的方法 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

addOperator, addSource, addSource, addSource, addSource, areExplicitEnvironmentsAllowed, clean, clearJobListeners, configure, configure, createInput, createInput, createLocalEnvironment, createLocalEnvironment, createLocalEnvironment, createLocalEnvironment, createLocalEnvironmentWithWebUI, createRemoteEnvironment, createRemoteEnvironment, createRemoteEnvironment, enableChangelogStateBackend, executeAsync, executeAsync, executeAsync, fromCollection, fromCollection, fromCollection, fromCollection, fromElements, fromElements, fromParallelCollection, fromParallelCollection, fromSequence, fromSource, fromSource, generateSequence, generateStreamGraph, getDefaultLocalParallelism, getDefaultSavepointDirectory, getExecutionEnvironment, getExecutionEnvironment, getJobListeners, getStreamGraph, getTransformations, getUserClassloader, initializeContextEnvironment, isChangelogStateBackendEnabled, isForceUnalignedCheckpoints, isUnalignedCheckpointsEnabled, readFile, readFile, readFile, readFile, readFileStream, readTextFile, readTextFile, registerJobListener, registerSlotSharingGroup, resetContextEnvironment, setDefaultLocalParallelism, setDefaultSavepointDirectory, setDefaultSavepointDirectory, setDefaultSavepointDirectory, setRuntimeMode, socketTextStream, socketTextStream, socketTextStream, socketTextStream, socketTextStream

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

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

构造器详细资料

DummyStreamExecutionEnvironment

public DummyStreamExecutionEnvironment(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment realExecEnv)

方法详细资料

getConfig

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

覆盖:

getConfig 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

getConfiguration

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

覆盖:

getConfiguration 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

getCachedFiles

public List<org.apache.flink.api.java.tuple.Tuple2<String,org.apache.flink.api.common.cache.DistributedCache.DistributedCacheEntry>> getCachedFiles()

覆盖:

getCachedFiles 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

setParallelism

public org.apache.flink.streaming.api.environment.StreamExecutionEnvironment setParallelism(int parallelism)

覆盖:

setParallelism 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

setMaxParallelism

public org.apache.flink.streaming.api.environment.StreamExecutionEnvironment setMaxParallelism(int maxParallelism)

覆盖:

setMaxParallelism 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

getParallelism

public int getParallelism()

覆盖:

getParallelism 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

getMaxParallelism

public int getMaxParallelism()

覆盖:

getMaxParallelism 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

setBufferTimeout

public org.apache.flink.streaming.api.environment.StreamExecutionEnvironment setBufferTimeout(long timeoutMillis)

覆盖:

setBufferTimeout 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

getBufferTimeout

public long getBufferTimeout()

覆盖:

getBufferTimeout 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

disableOperatorChaining

public org.apache.flink.streaming.api.environment.StreamExecutionEnvironment disableOperatorChaining()

覆盖:

disableOperatorChaining 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

isChainingEnabled

public boolean isChainingEnabled()

覆盖:

isChainingEnabled 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

getCheckpointConfig

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

覆盖:

getCheckpointConfig 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

enableCheckpointing

public org.apache.flink.streaming.api.environment.StreamExecutionEnvironment enableCheckpointing(long interval)

覆盖:

enableCheckpointing 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

enableCheckpointing

public org.apache.flink.streaming.api.environment.StreamExecutionEnvironment enableCheckpointing(long interval,
                                                                                                 org.apache.flink.streaming.api.CheckpointingMode mode)

覆盖:

enableCheckpointing 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

enableCheckpointing

public org.apache.flink.streaming.api.environment.StreamExecutionEnvironment enableCheckpointing(long interval,
                                                                                                 org.apache.flink.streaming.api.CheckpointingMode mode,
                                                                                                 boolean force)

覆盖:

enableCheckpointing 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

enableCheckpointing

public org.apache.flink.streaming.api.environment.StreamExecutionEnvironment enableCheckpointing()

覆盖:

enableCheckpointing 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

getCheckpointInterval

public long getCheckpointInterval()

覆盖:

getCheckpointInterval 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

isForceCheckpointing

public boolean isForceCheckpointing()

覆盖:

isForceCheckpointing 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

getCheckpointingMode

public org.apache.flink.streaming.api.CheckpointingMode getCheckpointingMode()

覆盖:

getCheckpointingMode 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

setStateBackend

public org.apache.flink.streaming.api.environment.StreamExecutionEnvironment setStateBackend(org.apache.flink.runtime.state.StateBackend backend)

覆盖:

setStateBackend 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

getStateBackend

public org.apache.flink.runtime.state.StateBackend getStateBackend()

覆盖:

getStateBackend 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

setRestartStrategy

public void setRestartStrategy(org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration restartStrategyConfiguration)

覆盖:

setRestartStrategy 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

getRestartStrategy

public org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration getRestartStrategy()

覆盖:

getRestartStrategy 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

setNumberOfExecutionRetries

public void setNumberOfExecutionRetries(int numberOfExecutionRetries)

覆盖:

setNumberOfExecutionRetries 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

getNumberOfExecutionRetries

public int getNumberOfExecutionRetries()

覆盖:

getNumberOfExecutionRetries 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

addDefaultKryoSerializer

public <T extends com.esotericsoftware.kryo.Serializer<?> & Serializable> void addDefaultKryoSerializer(Class<?> type,
                                                                                                        T serializer)

覆盖:

addDefaultKryoSerializer 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

addDefaultKryoSerializer

public void addDefaultKryoSerializer(Class<?> type,
                                     Class<? extends com.esotericsoftware.kryo.Serializer<?>> serializerClass)

覆盖:

addDefaultKryoSerializer 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

registerTypeWithKryoSerializer

public <T extends com.esotericsoftware.kryo.Serializer<?> & Serializable> void registerTypeWithKryoSerializer(Class<?> type,
                                                                                                              T serializer)

覆盖:

registerTypeWithKryoSerializer 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

registerTypeWithKryoSerializer

public void registerTypeWithKryoSerializer(Class<?> type,
                                           Class<? extends com.esotericsoftware.kryo.Serializer> serializerClass)

覆盖:

registerTypeWithKryoSerializer 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

registerType

public void registerType(Class<?> type)

覆盖:

registerType 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

setStreamTimeCharacteristic

public void setStreamTimeCharacteristic(org.apache.flink.streaming.api.TimeCharacteristic characteristic)

覆盖:

setStreamTimeCharacteristic 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

getStreamTimeCharacteristic

public org.apache.flink.streaming.api.TimeCharacteristic getStreamTimeCharacteristic()

覆盖:

getStreamTimeCharacteristic 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

execute

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

覆盖:

execute 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

抛出:

Exception

execute

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

覆盖:

execute 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

抛出:

Exception

execute

public org.apache.flink.api.common.JobExecutionResult execute(org.apache.flink.streaming.api.graph.StreamGraph streamGraph)
                                                       throws Exception

覆盖:

execute 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

抛出:

Exception

registerCachedFile

public void registerCachedFile(String filePath,
                               String name)

覆盖:

registerCachedFile 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

registerCachedFile

public void registerCachedFile(String filePath,
                               String name,
                               boolean executable)

覆盖:

registerCachedFile 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

getStreamGraph

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

覆盖:

getStreamGraph 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

getExecutionPlan

public String getExecutionPlan()

覆盖:

getExecutionPlan 在类中 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment