Runtime

class aws_cdk.aws_kinesisanalytics_flink_alpha.Runtime(*args: Any, **kwargs)

Bases: object

(experimental) Available Flink runtimes for Kinesis Analytics.

Stability:: experimental
ExampleMetadata:: lit=test/integ.application.lit.ts ! show infused

Example:

import path as path
import aws_cdk.aws_cloudwatch as cloudwatch
import aws_cdk as core
import aws_cdk.aws_kinesisanalytics_flink_alpha as flink

app = core.App()
stack = core.Stack(app, "FlinkAppTest")

flink_app = flink.Application(stack, "App",
    code=flink.ApplicationCode.from_asset(path.join(__dirname, "code-asset")),
    runtime=flink.Runtime.FLINK_1_19
)

cloudwatch.Alarm(stack, "Alarm",
    metric=flink_app.metric_full_restarts(),
    evaluation_periods=1,
    threshold=3
)

app.synth()

Attributes

FLINK_1_11 = <aws_cdk.aws_kinesisanalytics_flink_alpha.Runtime object>

FLINK_1_13 = <aws_cdk.aws_kinesisanalytics_flink_alpha.Runtime object>

FLINK_1_15 = <aws_cdk.aws_kinesisanalytics_flink_alpha.Runtime object>

FLINK_1_18 = <aws_cdk.aws_kinesisanalytics_flink_alpha.Runtime object>

FLINK_1_19 = <aws_cdk.aws_kinesisanalytics_flink_alpha.Runtime object>

FLINK_1_6 = <aws_cdk.aws_kinesisanalytics_flink_alpha.Runtime object>

FLINK_1_8 = <aws_cdk.aws_kinesisanalytics_flink_alpha.Runtime object>

value

(experimental) The Cfn string that represents a version of Flink.

Stability:: experimental

Static Methods

classmethod of(value)

(experimental) Create a new Runtime with with an arbitrary Flink version string.

Parameters:

value (str) –

Stability:

experimental

Return type:

Runtime