Uses of Class
org.apache.flink.api.common.ExecutionConfig

Packages that use ExecutionConfig

Package	Description
org.apache.flink.api.common
org.apache.flink.api.common.functions
org.apache.flink.api.common.functions.util
org.apache.flink.api.common.operators
org.apache.flink.api.common.operators.base
org.apache.flink.api.common.serialization
org.apache.flink.api.common.state
org.apache.flink.api.common.typeinfo
org.apache.flink.api.common.typeutils
org.apache.flink.api.java.typeutils
org.apache.flink.api.java.typeutils.runtime.kryo
org.apache.flink.streaming.api.operators

Uses of ExecutionConfig in org.apache.flink.api.common

Fields in org.apache.flink.api.common declared as ExecutionConfig

Modifier and Type	Field	Description
protected ExecutionConfig	Plan.executionConfig	Config object for runtime execution parameters.

Methods in org.apache.flink.api.common that return ExecutionConfig

Modifier and Type	Method	Description
ExecutionConfig	ExecutionConfig.disableClosureCleaner()	Disables the ClosureCleaner.
ExecutionConfig	ExecutionConfig.disableObjectReuse()	Disables reusing objects that Flink internally uses for deserialization and passing data to user-code functions.
ExecutionConfig	ExecutionConfig.enableClosureCleaner()	Enables the ClosureCleaner.
ExecutionConfig	ExecutionConfig.enableObjectReuse()	Enables reusing objects that Flink internally uses for deserialization and passing data to user-code functions.
ExecutionConfig	Plan.getExecutionConfig()	Gets the execution config object.
ExecutionConfig	ExecutionConfig.setAsyncInflightRecordsLimit(int limit)
ExecutionConfig	ExecutionConfig.setAsyncStateBufferSize(int bufferSize)
ExecutionConfig	ExecutionConfig.setAsyncStateBufferTimeout(long timeout)
ExecutionConfig	ExecutionConfig.setAutoWatermarkInterval(long interval)	Sets the interval of the automatic watermark emission.
ExecutionConfig	ExecutionConfig.setClosureCleanerLevel(ExecutionConfig.ClosureCleanerLevel level)	Configures the closure cleaner.
ExecutionConfig	ExecutionConfig.setExecutionRetryDelay(long executionRetryDelay)	Deprecated. This method will be replaced by setRestartStrategy(org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration).
ExecutionConfig	ExecutionConfig.setLatencyTrackingInterval(long interval)	Interval for sending latency tracking marks from the sources to the sinks.
ExecutionConfig	ExecutionConfig.setNumberOfExecutionRetries(int numberOfExecutionRetries)	Deprecated. This method will be replaced by setRestartStrategy(org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration).
ExecutionConfig	ExecutionConfig.setParallelism(int parallelism)	Sets the parallelism for operations executed through this environment.
ExecutionConfig	ExecutionConfig.setTaskCancellationInterval(long interval)	Sets the configuration parameter specifying the interval (in milliseconds) between consecutive attempts to cancel a running task.
ExecutionConfig	ExecutionConfig.setTaskCancellationTimeout(long timeout)	Sets the timeout (in milliseconds) after which an ongoing task cancellation is considered failed, leading to a fatal TaskManager error.

Methods in org.apache.flink.api.common with parameters of type ExecutionConfig

Modifier and Type	Method	Description
void	Plan.setExecutionConfig(ExecutionConfig executionConfig)	Sets the runtime config object defining execution parameters.

Constructors in org.apache.flink.api.common with parameters of type ExecutionConfig

Constructor	Description
ArchivedExecutionConfig(ExecutionConfig ec)

Uses of ExecutionConfig in org.apache.flink.api.common.functions

Methods in org.apache.flink.api.common.functions that return ExecutionConfig

Modifier and Type	Method	Description
ExecutionConfig	RuntimeContext.getExecutionConfig()	Deprecated. This method has been deprecated and will be removed in the upcoming FLINK major version FLINK-2.0.

Uses of ExecutionConfig in org.apache.flink.api.common.functions.util

Methods in org.apache.flink.api.common.functions.util that return ExecutionConfig

Modifier and Type	Method	Description
ExecutionConfig	AbstractRuntimeUDFContext.getExecutionConfig()	Deprecated.

Constructors in org.apache.flink.api.common.functions.util with parameters of type ExecutionConfig

Constructor	Description
AbstractRuntimeUDFContext(JobInfo jobInfo, TaskInfo taskInfo, UserCodeClassLoader userCodeClassLoader, ExecutionConfig executionConfig, Map<String,Accumulator<?,?>> accumulators, Map<String,Future<Path>> cpTasks, org.apache.flink.metrics.groups.OperatorMetricGroup metrics)
RuntimeUDFContext(JobInfo jobInfo, TaskInfo taskInfo, ClassLoader userCodeClassLoader, ExecutionConfig executionConfig, Map<String,Future<Path>> cpTasks, Map<String,Accumulator<?,?>> accumulators, org.apache.flink.metrics.groups.OperatorMetricGroup metrics)
RuntimeUDFContext(TaskInfo taskInfo, ClassLoader userCodeClassLoader, ExecutionConfig executionConfig, Map<String,Future<Path>> cpTasks, Map<String,Accumulator<?,?>> accumulators, org.apache.flink.metrics.groups.OperatorMetricGroup metrics)

Uses of ExecutionConfig in org.apache.flink.api.common.operators

Methods in org.apache.flink.api.common.operators with parameters of type ExecutionConfig

Modifier and Type	Method	Description
protected abstract List<OUT>	DualInputOperator.executeOnCollections(List<IN1> inputData1, List<IN2> inputData2, RuntimeContext runtimeContext, ExecutionConfig executionConfig)
protected void	GenericDataSinkBase.executeOnCollections(List<IN> inputData, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<OUT>	GenericDataSourceBase.executeOnCollections(RuntimeContext ctx, ExecutionConfig executionConfig)
protected abstract List<OUT>	SingleInputOperator.executeOnCollections(List<IN> inputData, RuntimeContext runtimeContext, ExecutionConfig executionConfig)
protected List<T>	Union.executeOnCollections(List<T> inputData1, List<T> inputData2, RuntimeContext runtimeContext, ExecutionConfig executionConfig)

Constructors in org.apache.flink.api.common.operators with parameters of type ExecutionConfig

Constructor	Description
CollectionExecutor(ExecutionConfig executionConfig)

Uses of ExecutionConfig in org.apache.flink.api.common.operators.base

Methods in org.apache.flink.api.common.operators.base with parameters of type ExecutionConfig

Modifier and Type	Method	Description
protected List<T>	BulkIterationBase.executeOnCollections(List<T> inputData, RuntimeContext runtimeContext, ExecutionConfig executionConfig)
protected List<OUT>	CoGroupOperatorBase.executeOnCollections(List<IN1> input1, List<IN2> input2, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<OUT>	CoGroupRawOperatorBase.executeOnCollections(List<IN1> input1, List<IN2> input2, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<OUT>	CrossOperatorBase.executeOnCollections(List<IN1> inputData1, List<IN2> inputData2, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<ST>	DeltaIterationBase.executeOnCollections(List<ST> inputData1, List<WT> inputData2, RuntimeContext runtimeContext, ExecutionConfig executionConfig)
protected List<T>	FilterOperatorBase.executeOnCollections(List<T> inputData, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<OUT>	FlatMapOperatorBase.executeOnCollections(List<IN> input, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<OUT>	GroupCombineOperatorBase.executeOnCollections(List<IN> inputData, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<OUT>	GroupReduceOperatorBase.executeOnCollections(List<IN> inputData, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<OUT>	InnerJoinOperatorBase.executeOnCollections(List<IN1> inputData1, List<IN2> inputData2, RuntimeContext runtimeContext, ExecutionConfig executionConfig)
protected List<OUT>	MapOperatorBase.executeOnCollections(List<IN> inputData, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<OUT>	MapPartitionOperatorBase.executeOnCollections(List<IN> inputData, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<OUT>	OuterJoinOperatorBase.executeOnCollections(List<IN1> leftInput, List<IN2> rightInput, RuntimeContext runtimeContext, ExecutionConfig executionConfig)
protected List<IN>	PartitionOperatorBase.executeOnCollections(List<IN> inputData, RuntimeContext runtimeContext, ExecutionConfig executionConfig)
protected List<T>	ReduceOperatorBase.executeOnCollections(List<T> inputData, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<IN>	SortPartitionOperatorBase.executeOnCollections(List<IN> inputData, RuntimeContext runtimeContext, ExecutionConfig executionConfig)

Uses of ExecutionConfig in org.apache.flink.api.common.serialization

Methods in org.apache.flink.api.common.serialization that return ExecutionConfig

Modifier and Type	Method	Description
ExecutionConfig	SerializerConfigImpl.getExecutionConfig()	Note: This method is used only for compatibility while TypeInformation.createSerializer(ExecutionConfig) is deprecated; If it is removed, this method will also be removed.

Constructors in org.apache.flink.api.common.serialization with parameters of type ExecutionConfig

Constructor	Description
SerializerConfigImpl(Configuration configuration, ExecutionConfig executionConfig)
TypeInformationSerializationSchema(TypeInformation<T> typeInfo, ExecutionConfig ec)	Creates a new de-/serialization schema for the given type.

Uses of ExecutionConfig in org.apache.flink.api.common.state

Methods in org.apache.flink.api.common.state with parameters of type ExecutionConfig

Modifier and Type	Method	Description
void	StateDescriptor.initializeSerializerUnlessSet(ExecutionConfig executionConfig)	Initializes the serializer, unless it has been initialized before.

Uses of ExecutionConfig in org.apache.flink.api.common.typeinfo

Methods in org.apache.flink.api.common.typeinfo with parameters of type ExecutionConfig

Modifier and Type	Method	Description
TypeComparator<T>	AtomicType.createComparator(boolean sortOrderAscending, ExecutionConfig executionConfig)	Creates a comparator for this type.
TypeComparator<T>	BasicTypeInfo.createComparator(boolean sortOrderAscending, ExecutionConfig executionConfig)
TypeComparator<T>	LocalTimeTypeInfo.createComparator(boolean sortOrderAscending, ExecutionConfig executionConfig)
PrimitiveArrayComparator<T,?>	PrimitiveArrayTypeInfo.createComparator(boolean sortOrderAscending, ExecutionConfig executionConfig)
TypeComparator<T>	SqlTimeTypeInfo.createComparator(boolean sortOrderAscending, ExecutionConfig executionConfig)
TypeSerializer<T>	BasicArrayTypeInfo.createSerializer(ExecutionConfig config)	Deprecated.
TypeSerializer<T>	BasicTypeInfo.createSerializer(ExecutionConfig config)	Deprecated.
TypeSerializer<T>	LocalTimeTypeInfo.createSerializer(ExecutionConfig config)
TypeSerializer<Nothing>	NothingTypeInfo.createSerializer(ExecutionConfig config)	Deprecated.
TypeSerializer<T>	PrimitiveArrayTypeInfo.createSerializer(ExecutionConfig config)
TypeSerializer<T>	SqlTimeTypeInfo.createSerializer(ExecutionConfig config)
abstract TypeSerializer<T>	TypeInformation.createSerializer(ExecutionConfig config)	Deprecated. This method is deprecated since Flink 1.19 and will be removed in Flink 1.20.

Uses of ExecutionConfig in org.apache.flink.api.common.typeutils

Methods in org.apache.flink.api.common.typeutils with parameters of type ExecutionConfig

Modifier and Type	Method	Description
TypeComparator<T>	CompositeType.createComparator(int[] logicalKeyFields, boolean[] orders, int logicalFieldOffset, ExecutionConfig config)	Generic implementation of the comparator creation.
TypeComparator<T>	CompositeType.TypeComparatorBuilder.createTypeComparator(ExecutionConfig config)

Uses of ExecutionConfig in org.apache.flink.api.java.typeutils

Methods in org.apache.flink.api.java.typeutils with parameters of type ExecutionConfig

Modifier and Type	Method	Description
TypeComparator<T>	EnumTypeInfo.createComparator(boolean sortOrderAscending, ExecutionConfig executionConfig)
TypeComparator<T>	GenericTypeInfo.createComparator(boolean sortOrderAscending, ExecutionConfig executionConfig)
TypeComparator<Row>	RowTypeInfo.createComparator(int[] logicalKeyFields, boolean[] orders, int logicalFieldOffset, ExecutionConfig config)
TypeComparator<T>	ValueTypeInfo.createComparator(boolean sortOrderAscending, ExecutionConfig executionConfig)
PojoSerializer<T>	PojoTypeInfo.createPojoSerializer(ExecutionConfig config)	Deprecated.
TypeSerializer<Either<L,R>>	EitherTypeInfo.createSerializer(ExecutionConfig config)	Deprecated.
TypeSerializer<T>	EnumTypeInfo.createSerializer(ExecutionConfig config)	Deprecated.
TypeSerializer<T>	GenericTypeInfo.createSerializer(ExecutionConfig config)	Deprecated.
TypeSerializer<List<T>>	ListTypeInfo.createSerializer(ExecutionConfig config)
TypeSerializer<Map<K,V>>	MapTypeInfo.createSerializer(ExecutionConfig config)
TypeSerializer<InvalidTypesException>	MissingTypeInfo.createSerializer(ExecutionConfig config)
TypeSerializer<T>	ObjectArrayTypeInfo.createSerializer(ExecutionConfig config)	Deprecated.
TypeSerializer<T>	PojoTypeInfo.createSerializer(ExecutionConfig config)	Deprecated.
TypeSerializer<Row>	RowTypeInfo.createSerializer(ExecutionConfig config)
TypeSerializer<T>	TupleTypeInfo.createSerializer(ExecutionConfig config)	Deprecated.
TypeSerializer<T>	ValueTypeInfo.createSerializer(ExecutionConfig config)	Deprecated.
void	InputTypeConfigurable.setInputType(TypeInformation<?> type, ExecutionConfig executionConfig)	Method that is called on an OutputFormat when it is passed to the DataSet's output method.

Uses of ExecutionConfig in org.apache.flink.api.java.typeutils.runtime.kryo

Constructors in org.apache.flink.api.java.typeutils.runtime.kryo with parameters of type ExecutionConfig

Constructor	Description
KryoSerializer(Class<T> type, ExecutionConfig executionConfig)

Uses of ExecutionConfig in org.apache.flink.streaming.api.operators

Methods in org.apache.flink.streaming.api.operators with parameters of type ExecutionConfig

Modifier and Type	Method	Description
void	OutputTypeConfigurable.setOutputType(TypeInformation<OUT> outTypeInfo, ExecutionConfig executionConfig)	Is called by the org.apache.flink.streaming.api.graph.StreamGraph#addOperator(Integer, String, StreamOperator, TypeInformation, TypeInformation, String) method when the org.apache.flink.streaming.api.graph.StreamGraph is generated.