Class ParallelismConfigurationUpdate
- All Implemented Interfaces:
Serializable
,SdkPojo
,ToCopyableBuilder<ParallelismConfigurationUpdate.Builder,
ParallelismConfigurationUpdate>
Describes updates to parameters for how an application executes multiple tasks simultaneously.
- See Also:
-
Nested Class Summary
-
Method Summary
Modifier and TypeMethodDescriptionfinal Boolean
Describes updates to whether the Managed Service for Apache Flink service can increase the parallelism of a Managed Service for Apache Flink application in response to increased throughput.builder()
final ConfigurationType
Describes updates to whether the application uses the default parallelism for the Managed Service for Apache Flink service, or if a custom parallelism is used.final String
Describes updates to whether the application uses the default parallelism for the Managed Service for Apache Flink service, or if a custom parallelism is used.final boolean
final boolean
equalsBySdkFields
(Object obj) Indicates whether some other object is "equal to" this one by SDK fields.final <T> Optional
<T> getValueForField
(String fieldName, Class<T> clazz) final int
hashCode()
final Integer
Describes updates to the number of parallel tasks an application can perform per Kinesis Processing Unit (KPU) used by the application.final Integer
Describes updates to the initial number of parallel tasks an application can perform.static Class
<? extends ParallelismConfigurationUpdate.Builder> Take this object and create a builder that contains all of the current property values of this object.final String
toString()
Returns a string representation of this object.Methods inherited from interface software.amazon.awssdk.utils.builder.ToCopyableBuilder
copy
-
Method Details
-
configurationTypeUpdate
Describes updates to whether the application uses the default parallelism for the Managed Service for Apache Flink service, or if a custom parallelism is used. You must set this property to
CUSTOM
in order to change your application'sAutoScalingEnabled
,Parallelism
, orParallelismPerKPU
properties.If the service returns an enum value that is not available in the current SDK version,
configurationTypeUpdate
will returnConfigurationType.UNKNOWN_TO_SDK_VERSION
. The raw value returned by the service is available fromconfigurationTypeUpdateAsString()
.- Returns:
- Describes updates to whether the application uses the default parallelism for the Managed Service for
Apache Flink service, or if a custom parallelism is used. You must set this property to
CUSTOM
in order to change your application'sAutoScalingEnabled
,Parallelism
, orParallelismPerKPU
properties. - See Also:
-
configurationTypeUpdateAsString
Describes updates to whether the application uses the default parallelism for the Managed Service for Apache Flink service, or if a custom parallelism is used. You must set this property to
CUSTOM
in order to change your application'sAutoScalingEnabled
,Parallelism
, orParallelismPerKPU
properties.If the service returns an enum value that is not available in the current SDK version,
configurationTypeUpdate
will returnConfigurationType.UNKNOWN_TO_SDK_VERSION
. The raw value returned by the service is available fromconfigurationTypeUpdateAsString()
.- Returns:
- Describes updates to whether the application uses the default parallelism for the Managed Service for
Apache Flink service, or if a custom parallelism is used. You must set this property to
CUSTOM
in order to change your application'sAutoScalingEnabled
,Parallelism
, orParallelismPerKPU
properties. - See Also:
-
parallelismUpdate
Describes updates to the initial number of parallel tasks an application can perform. If
AutoScalingEnabled
is set to True, then Managed Service for Apache Flink can increase theCurrentParallelism
value in response to application load. The service can increaseCurrentParallelism
up to the maximum parallelism, which isParalellismPerKPU
times the maximum KPUs for the application. The maximum KPUs for an application is 32 by default, and can be increased by requesting a limit increase. If application load is reduced, the service will reduceCurrentParallelism
down to theParallelism
setting.- Returns:
- Describes updates to the initial number of parallel tasks an application can perform. If
AutoScalingEnabled
is set to True, then Managed Service for Apache Flink can increase theCurrentParallelism
value in response to application load. The service can increaseCurrentParallelism
up to the maximum parallelism, which isParalellismPerKPU
times the maximum KPUs for the application. The maximum KPUs for an application is 32 by default, and can be increased by requesting a limit increase. If application load is reduced, the service will reduceCurrentParallelism
down to theParallelism
setting.
-
parallelismPerKPUUpdate
Describes updates to the number of parallel tasks an application can perform per Kinesis Processing Unit (KPU) used by the application.
- Returns:
- Describes updates to the number of parallel tasks an application can perform per Kinesis Processing Unit (KPU) used by the application.
-
autoScalingEnabledUpdate
Describes updates to whether the Managed Service for Apache Flink service can increase the parallelism of a Managed Service for Apache Flink application in response to increased throughput.
- Returns:
- Describes updates to whether the Managed Service for Apache Flink service can increase the parallelism of a Managed Service for Apache Flink application in response to increased throughput.
-
toBuilder
Description copied from interface:ToCopyableBuilder
Take this object and create a builder that contains all of the current property values of this object.- Specified by:
toBuilder
in interfaceToCopyableBuilder<ParallelismConfigurationUpdate.Builder,
ParallelismConfigurationUpdate> - Returns:
- a builder for type T
-
builder
-
serializableBuilderClass
-
hashCode
public final int hashCode() -
equals
-
equalsBySdkFields
Description copied from interface:SdkPojo
Indicates whether some other object is "equal to" this one by SDK fields. An SDK field is a modeled, non-inherited field in anSdkPojo
class, and is generated based on a service model.If an
SdkPojo
class does not have any inherited fields,equalsBySdkFields
andequals
are essentially the same.- Specified by:
equalsBySdkFields
in interfaceSdkPojo
- Parameters:
obj
- the object to be compared with- Returns:
- true if the other object equals to this object by sdk fields, false otherwise.
-
toString
Returns a string representation of this object. This is useful for testing and debugging. Sensitive data will be redacted from this string using a placeholder value. -
getValueForField
-
sdkFields
-