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.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.state.v2
org.apache.flink.api.common.typeinfo
org.apache.flink.api.common.typeutils
org.apache.flink.api.java.typeutils
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.setAsyncStateActiveBufferSize(int bufferSize)
ExecutionConfig	ExecutionConfig.setAsyncStateActiveBufferTimeout(long timeout)
ExecutionConfig	ExecutionConfig.setAsyncStateTotalBufferSize(int limit)
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.setLatencyTrackingInterval(long interval)	Interval for sending latency tracking marks from the sources to the sinks.
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.util

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

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

Constructor	Description
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.state.v2

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

Modifier and Type	Method	Description
void	MapStateDescriptor.initializeSerializerUnlessSet(ExecutionConfig executionConfig)	Initializes the serializer, unless it has been initialized before.
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)

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)
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.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.