Interface FlinkApplicationConfiguration.Builder

All Superinterfaces:

Buildable, CopyableBuilder<FlinkApplicationConfiguration.Builder,FlinkApplicationConfiguration>, SdkBuilder<FlinkApplicationConfiguration.Builder,FlinkApplicationConfiguration>, SdkPojo

Enclosing class:

FlinkApplicationConfiguration

@Mutable
@NotThreadSafe
public static interface FlinkApplicationConfiguration.Builder
extends SdkPojo, CopyableBuilder<FlinkApplicationConfiguration.Builder,FlinkApplicationConfiguration>

Method Summary

Modifier and Type	Method	Description
default FlinkApplicationConfiguration.Builder	checkpointConfiguration(Consumer<CheckpointConfiguration.Builder> checkpointConfiguration)	Describes an application's checkpointing configuration.
FlinkApplicationConfiguration.Builder	checkpointConfiguration(CheckpointConfiguration checkpointConfiguration)	Describes an application's checkpointing configuration.
default FlinkApplicationConfiguration.Builder	monitoringConfiguration(Consumer<MonitoringConfiguration.Builder> monitoringConfiguration)	Describes configuration parameters for Amazon CloudWatch logging for an application.
FlinkApplicationConfiguration.Builder	monitoringConfiguration(MonitoringConfiguration monitoringConfiguration)	Describes configuration parameters for Amazon CloudWatch logging for an application.
default FlinkApplicationConfiguration.Builder	parallelismConfiguration(Consumer<ParallelismConfiguration.Builder> parallelismConfiguration)	Describes parameters for how an application executes multiple tasks simultaneously.
FlinkApplicationConfiguration.Builder	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, sdkFieldNameToField, 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 the CheckpointConfiguration.Builder avoiding the need to create one manually via CheckpointConfiguration.builder().

When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to checkpointConfiguration(CheckpointConfiguration).

Parameters:

checkpointConfiguration - a consumer that will call methods on CheckpointConfiguration.Builder

Returns:

Returns a reference to this object so that method calls can be chained together.

See Also:

• checkpointConfiguration(CheckpointConfiguration)

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 the MonitoringConfiguration.Builder avoiding the need to create one manually via MonitoringConfiguration.builder().

When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to monitoringConfiguration(MonitoringConfiguration).

Parameters:

monitoringConfiguration - a consumer that will call methods on MonitoringConfiguration.Builder

Returns:

Returns a reference to this object so that method calls can be chained together.

See Also:

• monitoringConfiguration(MonitoringConfiguration)

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 the ParallelismConfiguration.Builder avoiding the need to create one manually via ParallelismConfiguration.builder().

When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to parallelismConfiguration(ParallelismConfiguration).

Parameters:

parallelismConfiguration - a consumer that will call methods on ParallelismConfiguration.Builder

Returns:

Returns a reference to this object so that method calls can be chained together.

See Also:

• parallelismConfiguration(ParallelismConfiguration)