@Generated(value="com.amazonaws:aws-java-sdk-code-generator") public class ParallelismConfigurationDescription extends Object implements Serializable, Cloneable, StructuredPojo
Describes parameters for how a Managed Service for Apache Flink application executes multiple tasks simultaneously.
Constructor and Description |
---|
ParallelismConfigurationDescription() |
Modifier and Type | Method and Description |
---|---|
ParallelismConfigurationDescription |
clone() |
boolean |
equals(Object obj) |
Boolean |
getAutoScalingEnabled()
Describes whether the Managed Service for Apache Flink service can increase the parallelism of the application in
response to increased throughput.
|
String |
getConfigurationType()
Describes whether the application uses the default parallelism for the Managed Service for Apache Flink service.
|
Integer |
getCurrentParallelism()
Describes the current number of parallel tasks that a Managed Service for Apache Flink application can perform.
|
Integer |
getParallelism()
Describes the initial number of parallel tasks that a Managed Service for Apache Flink application can perform.
|
Integer |
getParallelismPerKPU()
Describes the number of parallel tasks that a Managed Service for Apache Flink application can perform per
Kinesis Processing Unit (KPU) used by the application.
|
int |
hashCode() |
Boolean |
isAutoScalingEnabled()
Describes whether the Managed Service for Apache Flink service can increase the parallelism of the application in
response to increased throughput.
|
void |
marshall(ProtocolMarshaller protocolMarshaller)
Marshalls this structured data using the given
ProtocolMarshaller . |
void |
setAutoScalingEnabled(Boolean autoScalingEnabled)
Describes whether the Managed Service for Apache Flink service can increase the parallelism of the application in
response to increased throughput.
|
void |
setConfigurationType(String configurationType)
Describes whether the application uses the default parallelism for the Managed Service for Apache Flink service.
|
void |
setCurrentParallelism(Integer currentParallelism)
Describes the current number of parallel tasks that a Managed Service for Apache Flink application can perform.
|
void |
setParallelism(Integer parallelism)
Describes the initial number of parallel tasks that a Managed Service for Apache Flink application can perform.
|
void |
setParallelismPerKPU(Integer parallelismPerKPU)
Describes the number of parallel tasks that a Managed Service for Apache Flink application can perform per
Kinesis Processing Unit (KPU) used by the application.
|
String |
toString()
Returns a string representation of this object.
|
ParallelismConfigurationDescription |
withAutoScalingEnabled(Boolean autoScalingEnabled)
Describes whether the Managed Service for Apache Flink service can increase the parallelism of the application in
response to increased throughput.
|
ParallelismConfigurationDescription |
withConfigurationType(ConfigurationType configurationType)
Describes whether the application uses the default parallelism for the Managed Service for Apache Flink service.
|
ParallelismConfigurationDescription |
withConfigurationType(String configurationType)
Describes whether the application uses the default parallelism for the Managed Service for Apache Flink service.
|
ParallelismConfigurationDescription |
withCurrentParallelism(Integer currentParallelism)
Describes the current number of parallel tasks that a Managed Service for Apache Flink application can perform.
|
ParallelismConfigurationDescription |
withParallelism(Integer parallelism)
Describes the initial number of parallel tasks that a Managed Service for Apache Flink application can perform.
|
ParallelismConfigurationDescription |
withParallelismPerKPU(Integer parallelismPerKPU)
Describes the number of parallel tasks that a Managed Service for Apache Flink application can perform per
Kinesis Processing Unit (KPU) used by the application.
|
public void setConfigurationType(String configurationType)
Describes whether the application uses the default parallelism for the Managed Service for Apache Flink service.
configurationType
- Describes whether the application uses the default parallelism for the Managed Service for Apache Flink
service.ConfigurationType
public String getConfigurationType()
Describes whether the application uses the default parallelism for the Managed Service for Apache Flink service.
ConfigurationType
public ParallelismConfigurationDescription withConfigurationType(String configurationType)
Describes whether the application uses the default parallelism for the Managed Service for Apache Flink service.
configurationType
- Describes whether the application uses the default parallelism for the Managed Service for Apache Flink
service.ConfigurationType
public ParallelismConfigurationDescription withConfigurationType(ConfigurationType configurationType)
Describes whether the application uses the default parallelism for the Managed Service for Apache Flink service.
configurationType
- Describes whether the application uses the default parallelism for the Managed Service for Apache Flink
service.ConfigurationType
public void setParallelism(Integer parallelism)
Describes the initial number of parallel tasks that a Managed Service for Apache Flink application can perform.
If AutoScalingEnabled
is set to True, then Managed Service for Apache Flink can increase the
CurrentParallelism
value in response to application load. The service can increase
CurrentParallelism
up to the maximum parallelism, which is ParalellismPerKPU
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 can reduce the
CurrentParallelism
value down to the Parallelism
setting.
parallelism
- Describes the initial number of parallel tasks that a Managed Service for Apache Flink application can
perform. If AutoScalingEnabled
is set to True, then Managed Service for Apache Flink can
increase the CurrentParallelism
value in response to application load. The service can
increase CurrentParallelism
up to the maximum parallelism, which is
ParalellismPerKPU
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 can reduce the CurrentParallelism
value down to the
Parallelism
setting.public Integer getParallelism()
Describes the initial number of parallel tasks that a Managed Service for Apache Flink application can perform.
If AutoScalingEnabled
is set to True, then Managed Service for Apache Flink can increase the
CurrentParallelism
value in response to application load. The service can increase
CurrentParallelism
up to the maximum parallelism, which is ParalellismPerKPU
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 can reduce the
CurrentParallelism
value down to the Parallelism
setting.
AutoScalingEnabled
is set to True, then Managed Service for Apache Flink can
increase the CurrentParallelism
value in response to application load. The service can
increase CurrentParallelism
up to the maximum parallelism, which is
ParalellismPerKPU
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 can reduce the CurrentParallelism
value down to the
Parallelism
setting.public ParallelismConfigurationDescription withParallelism(Integer parallelism)
Describes the initial number of parallel tasks that a Managed Service for Apache Flink application can perform.
If AutoScalingEnabled
is set to True, then Managed Service for Apache Flink can increase the
CurrentParallelism
value in response to application load. The service can increase
CurrentParallelism
up to the maximum parallelism, which is ParalellismPerKPU
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 can reduce the
CurrentParallelism
value down to the Parallelism
setting.
parallelism
- Describes the initial number of parallel tasks that a Managed Service for Apache Flink application can
perform. If AutoScalingEnabled
is set to True, then Managed Service for Apache Flink can
increase the CurrentParallelism
value in response to application load. The service can
increase CurrentParallelism
up to the maximum parallelism, which is
ParalellismPerKPU
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 can reduce the CurrentParallelism
value down to the
Parallelism
setting.public void setParallelismPerKPU(Integer parallelismPerKPU)
Describes the number of parallel tasks that a Managed Service for Apache Flink application can perform per Kinesis Processing Unit (KPU) used by the application.
parallelismPerKPU
- Describes the number of parallel tasks that a Managed Service for Apache Flink application can perform per
Kinesis Processing Unit (KPU) used by the application.public Integer getParallelismPerKPU()
Describes the number of parallel tasks that a Managed Service for Apache Flink application can perform per Kinesis Processing Unit (KPU) used by the application.
public ParallelismConfigurationDescription withParallelismPerKPU(Integer parallelismPerKPU)
Describes the number of parallel tasks that a Managed Service for Apache Flink application can perform per Kinesis Processing Unit (KPU) used by the application.
parallelismPerKPU
- Describes the number of parallel tasks that a Managed Service for Apache Flink application can perform per
Kinesis Processing Unit (KPU) used by the application.public void setCurrentParallelism(Integer currentParallelism)
Describes the current number of parallel tasks that a Managed Service for Apache Flink application can perform.
If AutoScalingEnabled
is set to True, Managed Service for Apache Flink can increase this value in
response to application load. The service can increase this value up to the maximum parallelism, which is
ParalellismPerKPU
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
can reduce the CurrentParallelism
value down to the Parallelism
setting.
currentParallelism
- Describes the current number of parallel tasks that a Managed Service for Apache Flink application can
perform. If AutoScalingEnabled
is set to True, Managed Service for Apache Flink can increase
this value in response to application load. The service can increase this value up to the maximum
parallelism, which is ParalellismPerKPU
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 can reduce the CurrentParallelism
value down to the
Parallelism
setting.public Integer getCurrentParallelism()
Describes the current number of parallel tasks that a Managed Service for Apache Flink application can perform.
If AutoScalingEnabled
is set to True, Managed Service for Apache Flink can increase this value in
response to application load. The service can increase this value up to the maximum parallelism, which is
ParalellismPerKPU
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
can reduce the CurrentParallelism
value down to the Parallelism
setting.
AutoScalingEnabled
is set to True, Managed Service for Apache Flink can increase
this value in response to application load. The service can increase this value up to the maximum
parallelism, which is ParalellismPerKPU
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 can reduce the CurrentParallelism
value down to the
Parallelism
setting.public ParallelismConfigurationDescription withCurrentParallelism(Integer currentParallelism)
Describes the current number of parallel tasks that a Managed Service for Apache Flink application can perform.
If AutoScalingEnabled
is set to True, Managed Service for Apache Flink can increase this value in
response to application load. The service can increase this value up to the maximum parallelism, which is
ParalellismPerKPU
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
can reduce the CurrentParallelism
value down to the Parallelism
setting.
currentParallelism
- Describes the current number of parallel tasks that a Managed Service for Apache Flink application can
perform. If AutoScalingEnabled
is set to True, Managed Service for Apache Flink can increase
this value in response to application load. The service can increase this value up to the maximum
parallelism, which is ParalellismPerKPU
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 can reduce the CurrentParallelism
value down to the
Parallelism
setting.public void setAutoScalingEnabled(Boolean autoScalingEnabled)
Describes whether the Managed Service for Apache Flink service can increase the parallelism of the application in response to increased throughput.
autoScalingEnabled
- Describes whether the Managed Service for Apache Flink service can increase the parallelism of the
application in response to increased throughput.public Boolean getAutoScalingEnabled()
Describes whether the Managed Service for Apache Flink service can increase the parallelism of the application in response to increased throughput.
public ParallelismConfigurationDescription withAutoScalingEnabled(Boolean autoScalingEnabled)
Describes whether the Managed Service for Apache Flink service can increase the parallelism of the application in response to increased throughput.
autoScalingEnabled
- Describes whether the Managed Service for Apache Flink service can increase the parallelism of the
application in response to increased throughput.public Boolean isAutoScalingEnabled()
Describes whether the Managed Service for Apache Flink service can increase the parallelism of the application in response to increased throughput.
public String toString()
toString
in class Object
Object.toString()
public ParallelismConfigurationDescription clone()
public void marshall(ProtocolMarshaller protocolMarshaller)
StructuredPojo
ProtocolMarshaller
.marshall
in interface StructuredPojo
protocolMarshaller
- Implementation of ProtocolMarshaller
used to marshall this object's data.