public static interface FlinkApplicationConfiguration.Builder extends SdkPojo, CopyableBuilder<FlinkApplicationConfiguration.Builder,FlinkApplicationConfiguration>
Modifier and Type | Method and Description |
---|---|
FlinkApplicationConfiguration.Builder |
checkpointConfiguration(CheckpointConfiguration checkpointConfiguration)
Describes an application's checkpointing configuration.
|
default FlinkApplicationConfiguration.Builder |
checkpointConfiguration(Consumer<CheckpointConfiguration.Builder> 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.
|
copy
applyMutation, build
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.
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.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 that creates an instance of theCheckpointConfiguration.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)
.checkpointConfiguration
- a consumer that will call methods on CheckpointConfiguration.Builder
checkpointConfiguration(CheckpointConfiguration)
FlinkApplicationConfiguration.Builder monitoringConfiguration(MonitoringConfiguration monitoringConfiguration)
Describes configuration parameters for Amazon CloudWatch logging for an application.
monitoringConfiguration
- Describes configuration parameters for Amazon CloudWatch logging for an application.default FlinkApplicationConfiguration.Builder monitoringConfiguration(Consumer<MonitoringConfiguration.Builder> monitoringConfiguration)
Describes configuration parameters for Amazon CloudWatch logging for an application.
This is a convenience that creates an instance of theMonitoringConfiguration.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)
.monitoringConfiguration
- a consumer that will call methods on MonitoringConfiguration.Builder
monitoringConfiguration(MonitoringConfiguration)
FlinkApplicationConfiguration.Builder parallelismConfiguration(ParallelismConfiguration parallelismConfiguration)
Describes parameters for how an application executes multiple tasks simultaneously.
parallelismConfiguration
- Describes parameters for how an application executes multiple tasks simultaneously.default FlinkApplicationConfiguration.Builder parallelismConfiguration(Consumer<ParallelismConfiguration.Builder> parallelismConfiguration)
Describes parameters for how an application executes multiple tasks simultaneously.
This is a convenience that creates an instance of theParallelismConfiguration.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)
.parallelismConfiguration
- a consumer that will call methods on ParallelismConfiguration.Builder
parallelismConfiguration(ParallelismConfiguration)
Copyright © 2017 Amazon Web Services, Inc. All Rights Reserved.