Skip to content

FlinkApplicationConfiguration

Source code in docs_src/capo_kinesis_analytics_v2/types/flink_application_configuration.py 
13
14
15
16
17
18
19
20
21
22
23
24
25
class FlinkApplicationConfiguration(TypedDict, closed=True):
    checkpoint_configuration: NotRequired[
        "capo_kinesis_analytics_v2.types.checkpoint_configuration.CheckpointConfiguration"
    ]
    """<p>Describes an application's checkpointing configuration. Checkpointing is the process of persisting application state for fault tolerance. For more information, see <a href="https://nightlies.apache.org/flink/flink-docs-release-2.3/docs/dev/datastream/fault-tolerance/checkpointing/#enabling-and-configuring-checkpointing"> Checkpoints for Fault Tolerance</a> in the <a href="https://nightlies.apache.org/flink/flink-docs-release-2.3/">Apache Flink Documentation</a>. </p>"""
    monitoring_configuration: NotRequired[
        "capo_kinesis_analytics_v2.types.monitoring_configuration.MonitoringConfiguration"
    ]
    """<p>Describes configuration parameters for Amazon CloudWatch logging for an application.</p>"""
    parallelism_configuration: NotRequired[
        "capo_kinesis_analytics_v2.types.parallelism_configuration.ParallelismConfiguration"
    ]
    """<p>Describes parameters for how an application executes multiple tasks simultaneously.</p>"""

checkpoint_configuration: NotRequired[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. 

monitoring_configuration: NotRequired[MonitoringConfiguration]

Describes configuration parameters for Amazon CloudWatch logging for an application.

parallelism_configuration: NotRequired[ParallelismConfiguration]

Describes parameters for how an application executes multiple tasks simultaneously.