@Public public class ExecutionConfig extends Object implements Serializable, Archiveable<ArchivedExecutionConfig>
ExecutionMode
of the program: Batch or Pipelined. The default execution mode is
ExecutionMode.PIPELINED
Modifier and Type | Class and Description |
---|---|
static class |
ExecutionConfig.ClosureCleanerLevel
Configuration settings for the closure cleaner.
|
static class |
ExecutionConfig.GlobalJobParameters
Abstract class for a custom user configuration object registered at the execution config.
|
static class |
ExecutionConfig.SerializableSerializer<T extends com.esotericsoftware.kryo.Serializer<?> & Serializable>
Deprecated.
The class is deprecated because instance-type serializer definition where
serializers are serialized and written into the snapshot and deserialized for use is
deprecated. Use class-type serializer definition instead, where only the class name is
written into the snapshot and new instance of the serializer is created for use. This is
a breaking change, and it will be removed in Flink 2.0.
|
Modifier and Type | Field and Description |
---|---|
static int |
PARALLELISM_AUTO_MAX
Deprecated.
|
static int |
PARALLELISM_DEFAULT
The flag value indicating use of the default parallelism.
|
static int |
PARALLELISM_UNKNOWN
The flag value indicating an unknown or unset parallelism.
|
Constructor and Description |
---|
ExecutionConfig() |
ExecutionConfig(Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
void |
addDefaultKryoSerializer(Class<?> type,
Class<? extends com.esotericsoftware.kryo.Serializer<?>> serializerClass)
Deprecated.
Register data types and serializers through hard codes is deprecated, because you
need to modify the codes when upgrading job version. You should configure this by config
option
PipelineOptions.SERIALIZATION_CONFIG . |
<T extends com.esotericsoftware.kryo.Serializer<?> & Serializable> |
addDefaultKryoSerializer(Class<?> type,
T serializer)
Deprecated.
Register data types and serializers through hard codes is deprecated, because you
need to modify the codes when upgrading job version. You should configure this by config
option
PipelineOptions.SERIALIZATION_CONFIG . |
ArchivedExecutionConfig |
archive() |
boolean |
canEqual(Object obj)
Deprecated.
It is not intended to be used by users.
|
void |
configure(ReadableConfig configuration,
ClassLoader classLoader)
Sets all relevant options contained in the
ReadableConfig such as e.g. |
void |
disableAutoGeneratedUIDs()
Disables auto-generated UIDs.
|
void |
disableAutoTypeRegistration()
Deprecated.
The method is deprecated because it's only used in DataSet API. All Flink DataSet
APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version.
You can still build your application in DataSet, but you should move to either the
DataStream and/or Table API.
|
ExecutionConfig |
disableClosureCleaner()
Disables the ClosureCleaner.
|
void |
disableForceAvro()
Deprecated.
Configure serialization behavior through hard codes is deprecated, because you
need to modify the codes when upgrading job version. You should configure this by config
option
PipelineOptions.FORCE_AVRO . |
void |
disableForceKryo()
Deprecated.
Configure serialization behavior through hard codes is deprecated, because you
need to modify the codes when upgrading job version. You should configure this by config
option
PipelineOptions.FORCE_KRYO . |
void |
disableGenericTypes()
Deprecated.
Configure serialization behavior through hard codes is deprecated, because you
need to modify the codes when upgrading job version. You should configure this by config
option
PipelineOptions.GENERIC_TYPES . |
ExecutionConfig |
disableObjectReuse()
Disables reusing objects that Flink internally uses for deserialization and passing data to
user-code functions.
|
void |
enableAutoGeneratedUIDs()
Enables the Flink runtime to auto-generate UID's for operators.
|
ExecutionConfig |
enableClosureCleaner()
Enables the ClosureCleaner.
|
void |
enableForceAvro()
Deprecated.
Configure serialization behavior through hard codes is deprecated, because you
need to modify the codes when upgrading job version. You should configure this by config
option
PipelineOptions.FORCE_AVRO . |
void |
enableForceKryo()
Deprecated.
Configure serialization behavior through hard codes is deprecated, because you
need to modify the codes when upgrading job version. You should configure this by config
option
PipelineOptions.FORCE_KRYO . |
void |
enableGenericTypes()
Deprecated.
Configure serialization behavior through hard codes is deprecated, because you
need to modify the codes when upgrading job version. You should configure this by config
option
PipelineOptions.GENERIC_TYPES . |
ExecutionConfig |
enableObjectReuse()
Enables reusing objects that Flink internally uses for deserialization and passing data to
user-code functions.
|
void |
enablePeriodicMaterialize(boolean enabled) |
boolean |
equals(Object obj) |
int |
getAsyncInflightRecordsLimit() |
int |
getAsyncStateBufferSize() |
long |
getAsyncStateBufferTimeout() |
long |
getAutoWatermarkInterval()
Returns the interval of the automatic watermark emission.
|
ExecutionConfig.ClosureCleanerLevel |
getClosureCleanerLevel()
Returns the configured
ExecutionConfig.ClosureCleanerLevel . |
InputDependencyConstraint |
getDefaultInputDependencyConstraint()
Deprecated.
due to the deprecation of
InputDependencyConstraint . |
LinkedHashMap<Class<?>,Class<? extends com.esotericsoftware.kryo.Serializer<?>>> |
getDefaultKryoSerializerClasses()
Deprecated.
|
LinkedHashMap<Class<?>,ExecutionConfig.SerializableSerializer<?>> |
getDefaultKryoSerializers()
Deprecated.
|
ExecutionMode |
getExecutionMode()
Deprecated.
The
ExecutionMode is deprecated because it's only used in DataSet APIs.
All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future
Flink major version. You can still build your application in DataSet, but you should move
to either the DataStream and/or Table API. |
long |
getExecutionRetryDelay()
Deprecated.
Should no longer be used because it is subsumed by RestartStrategyConfiguration
|
ExecutionConfig.GlobalJobParameters |
getGlobalJobParameters() |
long |
getLatencyTrackingInterval()
Returns the latency tracking interval.
|
int |
getMaterializationMaxAllowedFailures() |
int |
getMaxParallelism()
Gets the maximum degree of parallelism defined for the program.
|
int |
getNumberOfExecutionRetries()
Deprecated.
Should no longer be used because it is subsumed by RestartStrategyConfiguration
|
int |
getParallelism()
Gets the parallelism with which operation are executed by default.
|
long |
getPeriodicMaterializeIntervalMillis() |
LinkedHashSet<Class<?>> |
getRegisteredKryoTypes()
Deprecated.
|
LinkedHashSet<Class<?>> |
getRegisteredPojoTypes()
Deprecated.
|
LinkedHashMap<Class<?>,Class<? extends com.esotericsoftware.kryo.Serializer<?>>> |
getRegisteredTypesWithKryoSerializerClasses()
Deprecated.
|
LinkedHashMap<Class<?>,ExecutionConfig.SerializableSerializer<?>> |
getRegisteredTypesWithKryoSerializers()
Deprecated.
|
RestartStrategies.RestartStrategyConfiguration |
getRestartStrategy()
Deprecated.
The method is marked as deprecated because starting from Flink 1.19, the usage of
all complex Java objects related to configuration, including their getter and setter
methods, should be replaced by ConfigOption. In a future major version of Flink, this
method will be removed entirely. It is recommended to switch to using the ConfigOptions
provided by
RestartStrategyOptions for configuring
restart strategies. |
Optional<JobManagerOptions.SchedulerType> |
getSchedulerType() |
SerializerConfig |
getSerializerConfig() |
long |
getTaskCancellationInterval()
Gets the interval (in milliseconds) between consecutive attempts to cancel a running task.
|
long |
getTaskCancellationTimeout()
Returns the timeout (in milliseconds) after which an ongoing task cancellation leads to a
fatal TaskManager error.
|
boolean |
hasAutoGeneratedUIDsEnabled()
Checks whether auto generated UIDs are supported.
|
boolean |
hasGenericTypesDisabled()
Deprecated.
|
int |
hashCode() |
boolean |
isAutoTypeRegistrationDisabled()
Deprecated.
The method is deprecated because it's only used in DataSet API. All Flink DataSet
APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version.
You can still build your application in DataSet, but you should move to either the
DataStream and/or Table API.
|
boolean |
isClosureCleanerEnabled()
Returns whether the ClosureCleaner is enabled.
|
boolean |
isForceAvroEnabled()
Deprecated.
|
boolean |
isForceKryoEnabled()
Deprecated.
|
boolean |
isLatencyTrackingConfigured() |
boolean |
isObjectReuseEnabled()
Returns whether object reuse has been enabled or disabled.
|
boolean |
isPeriodicMaterializeEnabled() |
boolean |
isUseSnapshotCompression() |
void |
registerKryoType(Class<?> type)
Deprecated.
Register data types and serializers through hard codes is deprecated, because you
need to modify the codes when upgrading job version. You should configure this by config
option
PipelineOptions.SERIALIZATION_CONFIG . |
void |
registerPojoType(Class<?> type)
Deprecated.
Register data types and serializers through hard codes is deprecated, because you
need to modify the codes when upgrading job version. You should configure this by config
option
PipelineOptions.SERIALIZATION_CONFIG . |
void |
registerTypeWithKryoSerializer(Class<?> type,
Class<? extends com.esotericsoftware.kryo.Serializer> serializerClass)
Deprecated.
Register data types and serializers through hard codes is deprecated, because you
need to modify the codes when upgrading job version. You should configure this by config
option
PipelineOptions.SERIALIZATION_CONFIG . |
<T extends com.esotericsoftware.kryo.Serializer<?> & Serializable> |
registerTypeWithKryoSerializer(Class<?> type,
T serializer)
Deprecated.
Register data types and serializers through hard codes is deprecated, because you
need to modify the codes when upgrading job version. You should configure this by config
option
PipelineOptions.SERIALIZATION_CONFIG . |
void |
resetParallelism() |
ExecutionConfig |
setAsyncInflightRecordsLimit(int limit) |
ExecutionConfig |
setAsyncStateBufferSize(int bufferSize) |
ExecutionConfig |
setAsyncStateBufferTimeout(long timeout) |
ExecutionConfig |
setAutoWatermarkInterval(long interval)
Sets the interval of the automatic watermark emission.
|
ExecutionConfig |
setClosureCleanerLevel(ExecutionConfig.ClosureCleanerLevel level)
Configures the closure cleaner.
|
void |
setDefaultInputDependencyConstraint(InputDependencyConstraint ignored)
Deprecated.
due to the deprecation of
InputDependencyConstraint . |
void |
setExecutionMode(ExecutionMode executionMode)
Deprecated.
The
ExecutionMode is deprecated because it's only used in DataSet APIs.
All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future
Flink major version. You can still build your application in DataSet, but you should move
to either the DataStream and/or Table API. |
ExecutionConfig |
setExecutionRetryDelay(long executionRetryDelay)
Deprecated.
This method will be replaced by
setRestartStrategy(org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration) . The RestartStrategies.FixedDelayRestartStrategyConfiguration contains the delay between
successive execution attempts. |
void |
setGlobalJobParameters(ExecutionConfig.GlobalJobParameters globalJobParameters)
Register a custom, serializable user configuration object.
|
ExecutionConfig |
setLatencyTrackingInterval(long interval)
Interval for sending latency tracking marks from the sources to the sinks.
|
void |
setMaterializationMaxAllowedFailures(int materializationMaxAllowedFailures) |
void |
setMaxParallelism(int maxParallelism)
Sets the maximum degree of parallelism defined for the program.
|
ExecutionConfig |
setNumberOfExecutionRetries(int numberOfExecutionRetries)
Deprecated.
This method will be replaced by
setRestartStrategy(org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration) . The RestartStrategies.FixedDelayRestartStrategyConfiguration contains the number of
execution retries. |
ExecutionConfig |
setParallelism(int parallelism)
Sets the parallelism for operations executed through this environment.
|
void |
setPeriodicMaterializeIntervalMillis(Duration periodicMaterializeInterval) |
void |
setRestartStrategy(RestartStrategies.RestartStrategyConfiguration restartStrategyConfiguration)
Deprecated.
The method is marked as deprecated because starting from Flink 1.19, the usage of
all complex Java objects related to configuration, including their getter and setter
methods, should be replaced by ConfigOption. In a future major version of Flink, this
method will be removed entirely. It is recommended to switch to using the ConfigOptions
provided by
RestartStrategyOptions for configuring
restart strategies. |
ExecutionConfig |
setTaskCancellationInterval(long interval)
Sets the configuration parameter specifying the interval (in milliseconds) between
consecutive attempts to cancel a running task.
|
ExecutionConfig |
setTaskCancellationTimeout(long timeout)
Sets the timeout (in milliseconds) after which an ongoing task cancellation is considered
failed, leading to a fatal TaskManager error.
|
void |
setUseSnapshotCompression(boolean useSnapshotCompression) |
Configuration |
toConfiguration() |
String |
toString() |
@Deprecated public static final int PARALLELISM_AUTO_MAX
public static final int PARALLELISM_DEFAULT
public static final int PARALLELISM_UNKNOWN
public ExecutionConfig()
@Internal public ExecutionConfig(Configuration configuration)
@Internal public SerializerConfig getSerializerConfig()
public ExecutionConfig enableClosureCleaner()
public ExecutionConfig disableClosureCleaner()
enableClosureCleaner()
public boolean isClosureCleanerEnabled()
enableClosureCleaner()
public ExecutionConfig setClosureCleanerLevel(ExecutionConfig.ClosureCleanerLevel level)
ExecutionConfig.ClosureCleanerLevel
for details on the
different settings.public ExecutionConfig.ClosureCleanerLevel getClosureCleanerLevel()
ExecutionConfig.ClosureCleanerLevel
.@PublicEvolving public ExecutionConfig setAutoWatermarkInterval(long interval)
Setting an interval of 0
will disable periodic watermark emission.
interval
- The interval between watermarks in milliseconds.@PublicEvolving public long getAutoWatermarkInterval()
setAutoWatermarkInterval(long)
@PublicEvolving public ExecutionConfig setLatencyTrackingInterval(long interval)
Setting a tracking interval <= 0 disables the latency tracking.
interval
- Interval in milliseconds.@PublicEvolving public long getLatencyTrackingInterval()
@Internal public boolean isLatencyTrackingConfigured()
@Internal public boolean isPeriodicMaterializeEnabled()
@Internal public void enablePeriodicMaterialize(boolean enabled)
@Internal public long getPeriodicMaterializeIntervalMillis()
@Internal public void setPeriodicMaterializeIntervalMillis(Duration periodicMaterializeInterval)
@Internal public int getMaterializationMaxAllowedFailures()
@Internal public void setMaterializationMaxAllowedFailures(int materializationMaxAllowedFailures)
public int getParallelism()
Other operations may need to run with a different parallelism - for example calling a reduce operation over the entire data set will involve an operation that runs with a parallelism of one (the final reduce to the single result value).
PARALLELISM_DEFAULT
if the environment's default parallelism should be
used.public ExecutionConfig setParallelism(int parallelism)
This method overrides the default parallelism for this environment. The local execution environment uses by default a value equal to the number of hardware contexts (CPU cores / threads). When executing the program via the command line client from a JAR file, the default parallelism is the one configured for that setup.
parallelism
- The parallelism to use@Internal public void resetParallelism()
@PublicEvolving public int getMaxParallelism()
The maximum degree of parallelism specifies the upper limit for dynamic scaling. It also defines the number of key groups used for partitioned state.
@PublicEvolving public void setMaxParallelism(int maxParallelism)
The maximum degree of parallelism specifies the upper limit for dynamic scaling. It also defines the number of key groups used for partitioned state.
maxParallelism
- Maximum degree of parallelism to be used for the program.public long getTaskCancellationInterval()
public ExecutionConfig setTaskCancellationInterval(long interval)
interval
- the interval (in milliseconds).@PublicEvolving public long getTaskCancellationTimeout()
The value 0
means that the timeout is disabled. In this case a stuck
cancellation will not lead to a fatal error.
@PublicEvolving public ExecutionConfig setTaskCancellationTimeout(long timeout)
The cluster default is configured via TaskManagerOptions.TASK_CANCELLATION_TIMEOUT
.
The value 0
disables the timeout. In this case a stuck cancellation will not
lead to a fatal error.
timeout
- The task cancellation timeout (in milliseconds).@Deprecated @PublicEvolving public void setRestartStrategy(RestartStrategies.RestartStrategyConfiguration restartStrategyConfiguration)
RestartStrategyOptions
for configuring
restart strategies.
ExecutionConfig config = env.getConfig();
config.setRestartStrategy(RestartStrategies.fixedDelayRestart(
10, // number of retries
1000 // delay between retries));
restartStrategyConfiguration
- Configuration defining the restart strategy to use@Deprecated @PublicEvolving public RestartStrategies.RestartStrategyConfiguration getRestartStrategy()
RestartStrategyOptions
for configuring
restart strategies.@Internal public Optional<JobManagerOptions.SchedulerType> getSchedulerType()
@Deprecated public int getNumberOfExecutionRetries()
-1
indicates that the system default value (as defined in the configuration) should be used.@Deprecated public long getExecutionRetryDelay()
@Deprecated public ExecutionConfig setNumberOfExecutionRetries(int numberOfExecutionRetries)
setRestartStrategy(org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration)
. The RestartStrategies.FixedDelayRestartStrategyConfiguration
contains the number of
execution retries.-1
indicates that the system default value (as
defined in the configuration) should be used.numberOfExecutionRetries
- The number of times the system will try to re-execute failed
tasks.@Deprecated public ExecutionConfig setExecutionRetryDelay(long executionRetryDelay)
setRestartStrategy(org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration)
. The RestartStrategies.FixedDelayRestartStrategyConfiguration
contains the delay between
successive execution attempts.executionRetryDelay
- The number of milliseconds the system will wait to retry.@Deprecated public void setExecutionMode(ExecutionMode executionMode)
ExecutionMode
is deprecated because it's only used in DataSet APIs.
All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future
Flink major version. You can still build your application in DataSet, but you should move
to either the DataStream and/or Table API.The default execution mode is ExecutionMode.PIPELINED
.
executionMode
- The execution mode to use.@Deprecated public ExecutionMode getExecutionMode()
ExecutionMode
is deprecated because it's only used in DataSet APIs.
All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future
Flink major version. You can still build your application in DataSet, but you should move
to either the DataStream and/or Table API.The default execution mode is ExecutionMode.PIPELINED
.
@PublicEvolving @Deprecated public void setDefaultInputDependencyConstraint(InputDependencyConstraint ignored)
InputDependencyConstraint
.InputDependencyConstraint
utilized
by the old scheduler implementations which got removed as part of FLINK-20589. The current
implementation has no effect.ignored
- Ignored parameter.@PublicEvolving @Deprecated public InputDependencyConstraint getDefaultInputDependencyConstraint()
InputDependencyConstraint
.InputDependencyConstraint
utilized by the old scheduler implementations. These implementations were removed as part of
FLINK-20589.InputDependencyConstraint.ANY
.@Deprecated public void enableForceKryo()
PipelineOptions.FORCE_KRYO
.@Deprecated public void disableForceKryo()
PipelineOptions.FORCE_KRYO
.@Deprecated public boolean isForceKryoEnabled()
SerializerConfig.isForceKryoEnabled()
.@Deprecated public void enableGenericTypes()
PipelineOptions.GENERIC_TYPES
.Generic types are enabled by default.
@Deprecated public void disableGenericTypes()
PipelineOptions.GENERIC_TYPES
.UnsupportedOperationException
whenever it encounters a
data type that would go through Kryo for serialization.
Disabling generic types can be helpful to eagerly find and eliminate the use of types that would go through Kryo serialization during runtime. Rather than checking types individually, using this option will throw exceptions eagerly in the places where generic types are used.
Important: We recommend to use this option only during development and pre-production phases, not during actual production use. The application program and/or the input data may be such that new, previously unseen, types occur at some point. In that case, setting this option would cause the program to fail.
@Deprecated public boolean hasGenericTypesDisabled()
SerializerConfig.hasGenericTypesDisabled()
.Generic types are enabled by default.
enableGenericTypes()
,
disableGenericTypes()
public void enableAutoGeneratedUIDs()
disableAutoGeneratedUIDs()
public void disableAutoGeneratedUIDs()
It is highly recommended that users specify UIDs before deploying to production since they are used to match state in savepoints to operators in a job. Because auto-generated ID's are likely to change when modifying a job, specifying custom IDs allow an application to evolve overtime without discarding state.
public boolean hasAutoGeneratedUIDsEnabled()
Auto generated UIDs are enabled by default.
@Deprecated public void enableForceAvro()
PipelineOptions.FORCE_AVRO
.Important: Make sure to include the flink-avro module.
@Deprecated public void disableForceAvro()
PipelineOptions.FORCE_AVRO
.@Deprecated public boolean isForceAvroEnabled()
SerializerConfig.isForceAvroEnabled()
.public ExecutionConfig enableObjectReuse()
public ExecutionConfig disableObjectReuse()
public boolean isObjectReuseEnabled()
public ExecutionConfig.GlobalJobParameters getGlobalJobParameters()
public void setGlobalJobParameters(ExecutionConfig.GlobalJobParameters globalJobParameters)
globalJobParameters
- Custom user configuration object@Deprecated public <T extends com.esotericsoftware.kryo.Serializer<?> & Serializable> void addDefaultKryoSerializer(Class<?> type, T serializer)
PipelineOptions.SERIALIZATION_CONFIG
.Note that the serializer instance must be serializable (as defined by java.io.Serializable), because it may be distributed to the worker nodes by java serialization.
type
- The class of the types serialized with the given serializer.serializer
- The serializer to use.@Deprecated public void addDefaultKryoSerializer(Class<?> type, Class<? extends com.esotericsoftware.kryo.Serializer<?>> serializerClass)
PipelineOptions.SERIALIZATION_CONFIG
.type
- The class of the types serialized with the given serializer.serializerClass
- The class of the serializer to use.@Deprecated public <T extends com.esotericsoftware.kryo.Serializer<?> & Serializable> void registerTypeWithKryoSerializer(Class<?> type, T serializer)
PipelineOptions.SERIALIZATION_CONFIG
.Note that the serializer instance must be serializable (as defined by java.io.Serializable), because it may be distributed to the worker nodes by java serialization.
type
- The class of the types serialized with the given serializer.serializer
- The serializer to use.@Deprecated public void registerTypeWithKryoSerializer(Class<?> type, Class<? extends com.esotericsoftware.kryo.Serializer> serializerClass)
PipelineOptions.SERIALIZATION_CONFIG
.type
- The class of the types serialized with the given serializer.serializerClass
- The class of the serializer to use.@Deprecated public void registerPojoType(Class<?> type)
PipelineOptions.SERIALIZATION_CONFIG
.type
- The class of the type to register.@Deprecated public void registerKryoType(Class<?> type)
PipelineOptions.SERIALIZATION_CONFIG
.type
- The class of the type to register.@Deprecated public LinkedHashMap<Class<?>,ExecutionConfig.SerializableSerializer<?>> getRegisteredTypesWithKryoSerializers()
SerializerConfig.getRegisteredTypesWithKryoSerializers()
.@Deprecated public LinkedHashMap<Class<?>,Class<? extends com.esotericsoftware.kryo.Serializer<?>>> getRegisteredTypesWithKryoSerializerClasses()
SerializerConfig.getRegisteredTypesWithKryoSerializerClasses()
.@Deprecated public LinkedHashMap<Class<?>,ExecutionConfig.SerializableSerializer<?>> getDefaultKryoSerializers()
SerializerConfig.getDefaultKryoSerializers()
.@Deprecated public LinkedHashMap<Class<?>,Class<? extends com.esotericsoftware.kryo.Serializer<?>>> getDefaultKryoSerializerClasses()
SerializerConfig.getDefaultKryoSerializerClasses()
.@Deprecated public LinkedHashSet<Class<?>> getRegisteredKryoTypes()
SerializerConfig.getRegisteredKryoTypes()
.@Deprecated public LinkedHashSet<Class<?>> getRegisteredPojoTypes()
SerializerConfig.getRegisteredPojoTypes()
.@Deprecated public boolean isAutoTypeRegistrationDisabled()
@Deprecated public void disableAutoTypeRegistration()
public boolean isUseSnapshotCompression()
public void setUseSnapshotCompression(boolean useSnapshotCompression)
@Experimental public int getAsyncInflightRecordsLimit()
@Experimental public ExecutionConfig setAsyncInflightRecordsLimit(int limit)
@Experimental public int getAsyncStateBufferSize()
@Experimental public ExecutionConfig setAsyncStateBufferSize(int bufferSize)
@Experimental public long getAsyncStateBufferTimeout()
@Experimental public ExecutionConfig setAsyncStateBufferTimeout(long timeout)
@Deprecated public boolean canEqual(Object obj)
ExecutionConfig
instance.@Internal public ArchivedExecutionConfig archive()
archive
in interface Archiveable<ArchivedExecutionConfig>
public void configure(ReadableConfig configuration, ClassLoader classLoader)
ReadableConfig
such as e.g. PipelineOptions.CLOSURE_CLEANER_LEVEL
.
It will change the value of a setting only if a corresponding option was set in the configuration
. If a key is not present, the current value of a field will remain untouched.
configuration
- a configuration to read the values fromclassLoader
- a class loader to use when loading classes@Internal public Configuration toConfiguration()
configuration
. Note it is missing all options that are
stored as plain java fields in ExecutionConfig
.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.