Runtime

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

Bases: object

(experimental) Available Flink runtimes for Kinesis Analytics.

Stability:: experimental
ExampleMetadata:: infused

Example:

# bucket: s3.Bucket

flink_app = flink.Application(self, "Application",
    property_groups={
        "FlinkApplicationProperties": {
            "input_stream_name": "my-input-kinesis-stream",
            "output_stream_name": "my-output-kinesis-stream"
        }
    },
    # ...
    runtime=flink.Runtime.FLINK_1_20,
    code=flink.ApplicationCode.from_bucket(bucket, "my-app.jar")
)

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_20 = <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>

SQL_1_0 = <aws_cdk.aws_kinesisanalytics_flink_alpha.Runtime object>

ZEPPELIN_FLINK_1_0 = <aws_cdk.aws_kinesisanalytics_flink_alpha.Runtime object>

ZEPPELIN_FLINK_2_0 = <aws_cdk.aws_kinesisanalytics_flink_alpha.Runtime object>

ZEPPELIN_FLINK_3_0 = <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