class Runtime 🔹

Language	Type name
.NET	Amazon.CDK.AWS.KinesisAnalyticsFlink.Runtime
Java	software.amazon.awscdk.services.kinesis.analytics.flink.Runtime
Python	aws_cdk.aws_kinesisanalytics_flink.Runtime
TypeScript (source)	@aws-cdk/aws-kinesisanalytics-flink » Runtime

Available Flink runtimes for Kinesis Analytics.

Example

import * as path from 'path';
import * as core from '@aws-cdk/core';
import * as flink from '../lib';
import * as cloudwatch from '@aws-cdk/aws-cloudwatch';

const app = new core.App();
const stack = new core.Stack(app, 'FlinkAppTest');

const flinkApp = new flink.Application(stack, 'App', {
  code: flink.ApplicationCode.fromAsset(path.join(__dirname, 'code-asset')),
  runtime: flink.Runtime.FLINK_1_11,
});

new cloudwatch.Alarm(stack, 'Alarm', {
  metric: flinkApp.metricFullRestarts(),
  evaluationPeriods: 1,
  threshold: 3,
});
///! hide

app.synth();

Properties

Name	Type	Description
value🔹	string	The Cfn string that represents a version of Flink.
static FLINK_1_11🔹	Runtime	Flink Version 1.11.
static FLINK_1_13🔹	Runtime	Flink Version 1.13.
static FLINK_1_6🔹	Runtime	Flink Version 1.6.
static FLINK_1_8🔹	Runtime	Flink Version 1.8.

---

value🔹

Type: string

The Cfn string that represents a version of Flink.

---

static FLINK_1_11🔹

Type: Runtime

Flink Version 1.11.

---

static FLINK_1_13🔹

Type: Runtime

Flink Version 1.13.

---

static FLINK_1_6🔹

Type: Runtime

Flink Version 1.6.

---

static FLINK_1_8🔹

Type: Runtime

Flink Version 1.8.

Methods

Name	Description
static of(value)🔹	Create a new Runtime with with an arbitrary Flink version string.

---

static of(value)🔹

public static of(value: string): Runtime

Parameters

• value string

Returns

• Runtime

Create a new Runtime with with an arbitrary Flink version string.