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
org.apache.flink.api.java.typeutils.runtime.kryo

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.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()	Returns the ExecutionConfig for the currently executing job.

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

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

Constructor	Description
AbstractRuntimeUDFContext(TaskInfo taskInfo, UserCodeClassLoader userCodeClassLoader, ExecutionConfig executionConfig, Map<String,Accumulator<?,?>> accumulators, Map<String,Future<Path>> cpTasks, 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)
RuntimeUDFContext(TaskInfo taskInfo, ClassLoader userCodeClassLoader, ExecutionConfig executionConfig, Map<String,Future<Path>> cpTasks, Map<String,Accumulator<?,?>> accumulators, org.apache.flink.metrics.groups.OperatorMetricGroup metrics, JobID jobID)

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.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 executionConfig)
TypeSerializer<T>	BasicTypeInfo.createSerializer(ExecutionConfig executionConfig)
TypeSerializer<T>	LocalTimeTypeInfo.createSerializer(ExecutionConfig executionConfig)
TypeSerializer<Nothing>	NothingTypeInfo.createSerializer(ExecutionConfig executionConfig)
TypeSerializer<T>	PrimitiveArrayTypeInfo.createSerializer(ExecutionConfig executionConfig)
TypeSerializer<T>	SqlTimeTypeInfo.createSerializer(ExecutionConfig executionConfig)
abstract TypeSerializer<T>	TypeInformation.createSerializer(ExecutionConfig config)	Creates a serializer for the type.

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
abstract void	AvroUtils.addAvroSerializersIfRequired(ExecutionConfig reg, Class<?> type)	Loads the utility class from flink-avro and adds Avro-specific serializers.
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)
TypeSerializer<Row>	RowTypeInfo.createLegacySerializer(ExecutionConfig config)	Deprecated.
PojoSerializer<T>	PojoTypeInfo.createPojoSerializer(ExecutionConfig config)
TypeSerializer<Either<L,R>>	EitherTypeInfo.createSerializer(ExecutionConfig config)
TypeSerializer<T>	EnumTypeInfo.createSerializer(ExecutionConfig executionConfig)
TypeSerializer<T>	GenericTypeInfo.createSerializer(ExecutionConfig config)
TypeSerializer<List<T>>	ListTypeInfo.createSerializer(ExecutionConfig config)
TypeSerializer<Map<K,V>>	MapTypeInfo.createSerializer(ExecutionConfig config)
TypeSerializer<InvalidTypesException>	MissingTypeInfo.createSerializer(ExecutionConfig executionConfig)
TypeSerializer<T>	ObjectArrayTypeInfo.createSerializer(ExecutionConfig executionConfig)
TypeSerializer<T>	PojoTypeInfo.createSerializer(ExecutionConfig config)
TypeSerializer<Row>	RowTypeInfo.createSerializer(ExecutionConfig config)
TupleSerializer<T>	TupleTypeInfo.createSerializer(ExecutionConfig executionConfig)
TypeSerializer<T>	ValueTypeInfo.createSerializer(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.api.java.typeutils.runtime

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

Constructor	Description
PojoSerializer(Class<T> clazz, TypeSerializer<?>[] fieldSerializers, Field[] fields, ExecutionConfig executionConfig)	Constructor to create a new PojoSerializer.

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

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

Modifier and Type	Method	Description
static void	Serializers.recursivelyRegisterType(Class<?> type, ExecutionConfig config, Set<Class<?>> alreadySeen)
static void	Serializers.recursivelyRegisterType(TypeInformation<?> typeInfo, ExecutionConfig config, Set<Class<?>> alreadySeen)

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

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