Interface FlinkApplicationConfiguration.Builder
- All Superinterfaces:
Buildable
,CopyableBuilder<FlinkApplicationConfiguration.Builder,
,FlinkApplicationConfiguration> SdkBuilder<FlinkApplicationConfiguration.Builder,
,FlinkApplicationConfiguration> SdkPojo
- Enclosing class:
FlinkApplicationConfiguration
-
Method Summary
Modifier and TypeMethodDescriptioncheckpointConfiguration
(Consumer<CheckpointConfiguration.Builder> checkpointConfiguration) Describes an application's checkpointing configuration.checkpointConfiguration
(CheckpointConfiguration checkpointConfiguration) Describes an application's checkpointing configuration.monitoringConfiguration
(Consumer<MonitoringConfiguration.Builder> monitoringConfiguration) Describes configuration parameters for Amazon CloudWatch logging for an application.monitoringConfiguration
(MonitoringConfiguration monitoringConfiguration) Describes configuration parameters for Amazon CloudWatch logging for an application.parallelismConfiguration
(Consumer<ParallelismConfiguration.Builder> parallelismConfiguration) Describes parameters for how an application executes multiple tasks simultaneously.parallelismConfiguration
(ParallelismConfiguration parallelismConfiguration) Describes parameters for how an application executes multiple tasks simultaneously.Methods inherited from interface software.amazon.awssdk.utils.builder.CopyableBuilder
copy
Methods inherited from interface software.amazon.awssdk.utils.builder.SdkBuilder
applyMutation, build
Methods inherited from interface software.amazon.awssdk.core.SdkPojo
equalsBySdkFields, sdkFields
-
Method Details
-
checkpointConfiguration
FlinkApplicationConfiguration.Builder checkpointConfiguration(CheckpointConfiguration checkpointConfiguration) Describes an application's checkpointing configuration. Checkpointing is the process of persisting application state for fault tolerance. For more information, see Checkpoints for Fault Tolerance in the Apache Flink Documentation.
- Parameters:
checkpointConfiguration
- Describes an application's checkpointing configuration. Checkpointing is the process of persisting application state for fault tolerance. For more information, see Checkpoints for Fault Tolerance in the Apache Flink Documentation.- Returns:
- Returns a reference to this object so that method calls can be chained together.
-
checkpointConfiguration
default FlinkApplicationConfiguration.Builder checkpointConfiguration(Consumer<CheckpointConfiguration.Builder> checkpointConfiguration) Describes an application's checkpointing configuration. Checkpointing is the process of persisting application state for fault tolerance. For more information, see Checkpoints for Fault Tolerance in the Apache Flink Documentation.
This is a convenience method that creates an instance of theCheckpointConfiguration.Builder
avoiding the need to create one manually viaCheckpointConfiguration.builder()
.When the
Consumer
completes,SdkBuilder.build()
is called immediately and its result is passed tocheckpointConfiguration(CheckpointConfiguration)
.- Parameters:
checkpointConfiguration
- a consumer that will call methods onCheckpointConfiguration.Builder
- Returns:
- Returns a reference to this object so that method calls can be chained together.
- See Also:
-
monitoringConfiguration
FlinkApplicationConfiguration.Builder monitoringConfiguration(MonitoringConfiguration monitoringConfiguration) Describes configuration parameters for Amazon CloudWatch logging for an application.
- Parameters:
monitoringConfiguration
- Describes configuration parameters for Amazon CloudWatch logging for an application.- Returns:
- Returns a reference to this object so that method calls can be chained together.
-
monitoringConfiguration
default FlinkApplicationConfiguration.Builder monitoringConfiguration(Consumer<MonitoringConfiguration.Builder> monitoringConfiguration) Describes configuration parameters for Amazon CloudWatch logging for an application.
This is a convenience method that creates an instance of theMonitoringConfiguration.Builder
avoiding the need to create one manually viaMonitoringConfiguration.builder()
.When the
Consumer
completes,SdkBuilder.build()
is called immediately and its result is passed tomonitoringConfiguration(MonitoringConfiguration)
.- Parameters:
monitoringConfiguration
- a consumer that will call methods onMonitoringConfiguration.Builder
- Returns:
- Returns a reference to this object so that method calls can be chained together.
- See Also:
-
parallelismConfiguration
FlinkApplicationConfiguration.Builder parallelismConfiguration(ParallelismConfiguration parallelismConfiguration) Describes parameters for how an application executes multiple tasks simultaneously.
- Parameters:
parallelismConfiguration
- Describes parameters for how an application executes multiple tasks simultaneously.- Returns:
- Returns a reference to this object so that method calls can be chained together.
-
parallelismConfiguration
default FlinkApplicationConfiguration.Builder parallelismConfiguration(Consumer<ParallelismConfiguration.Builder> parallelismConfiguration) Describes parameters for how an application executes multiple tasks simultaneously.
This is a convenience method that creates an instance of theParallelismConfiguration.Builder
avoiding the need to create one manually viaParallelismConfiguration.builder()
.When the
Consumer
completes,SdkBuilder.build()
is called immediately and its result is passed toparallelismConfiguration(ParallelismConfiguration)
.- Parameters:
parallelismConfiguration
- a consumer that will call methods onParallelismConfiguration.Builder
- Returns:
- Returns a reference to this object so that method calls can be chained together.
- See Also:
-