JarCasting
JarCasting JarCasting

AWS Kinesis Analytics Java Flink Runtime

This library contains the Kinesis Analytics Java stream processing runtime configuration classes.

License

License
Categories

Categories

AWS Container PaaS Providers
GroupId

GroupId

com.amazonaws
ArtifactId

ArtifactId

aws-kinesisanalytics-runtime
Last Version

Last Version

1.2.0
Release Date

Release Date
Type

Type

jar
Description

Description

AWS Kinesis Analytics Java Flink Runtime
This library contains the Kinesis Analytics Java stream processing runtime configuration classes.
Project URL

Project URL

https://aws.amazon.com/kinesis/data-analytics/
Source Code Management

Source Code Management

https://github.com/aws/aws-kinesisanalytics-runtime/tree/master

Download aws-kinesisanalytics-runtime

Filename Size
aws-kinesisanalytics-runtime-1.2.0.pom
aws-kinesisanalytics-runtime-1.2.0.jar 8 KB
aws-kinesisanalytics-runtime-1.2.0-sources.jar 8 KB
aws-kinesisanalytics-runtime-1.2.0-javadoc.jar 48 KB
Browse

How to add to project

<!-- https://jarcasting.com/artifacts/com.amazonaws/aws-kinesisanalytics-runtime/ -->
<dependency>
    <groupId>com.amazonaws</groupId>
    <artifactId>aws-kinesisanalytics-runtime</artifactId>
    <version>1.2.0</version>
</dependency>
// https://jarcasting.com/artifacts/com.amazonaws/aws-kinesisanalytics-runtime/
implementation 'com.amazonaws:aws-kinesisanalytics-runtime:1.2.0'
// https://jarcasting.com/artifacts/com.amazonaws/aws-kinesisanalytics-runtime/
implementation ("com.amazonaws:aws-kinesisanalytics-runtime:1.2.0")
'com.amazonaws:aws-kinesisanalytics-runtime:jar:1.2.0'
<dependency org="com.amazonaws" name="aws-kinesisanalytics-runtime" rev="1.2.0">
  <artifact name="aws-kinesisanalytics-runtime" type="jar" />
</dependency>
@Grapes(
@Grab(group='com.amazonaws', module='aws-kinesisanalytics-runtime', version='1.2.0')
)
libraryDependencies += "com.amazonaws" % "aws-kinesisanalytics-runtime" % "1.2.0"
[com.amazonaws/aws-kinesisanalytics-runtime "1.2.0"]

Dependencies

provided (2)

Group / Artifact Type Version
org.apache.flink : flink-core jar 1.8.3
org.apache.flink : flink-shaded-jackson jar 2.7.9-4.0

test (2)

Group / Artifact Type Version
junit : junit jar 4.13
org.assertj : assertj-core jar 3.16.1

Project Modules

There are no modules declared in this project.

AWS Kinesis Analytics Flink Runtime

This library can be used to access externalised KDA Flink application properties at runtime. See the documentation for a guide on how to configure properties in your KDA application.

Quickstart

Access properties configured via the AWS Console/SDK using:

Properties properties = KinesisAnalyticsRuntime.getApplicationProperties().get("app-group");
String inputStreamName = properties.getProperty("inputStreamName");
String outputStreamName = properties.getProperty("outputStreamName");

Building from Source

  1. You will need to install Java 1.8+ and Maven
  2. Clone the repository from Github
  3. Build using Maven from the project root directory:
    1. $ mvn clean install

Flink Version Matrix

This project is compatible with Flink 1.x, there is no guarantee it will support Flink 2.x should it release in the future.

Connector Version Flink Version Release Date
1.1.0 1.x Dec, 2019
1.0.1 1.x Dec, 2018
1.0.0 1.x Dec, 2018

License

This library is licensed under the Apache 2.0 License.

com.amazonaws

Amazon Web Services

Versions

Version
1.2.0
1.1.0
1.0.1
1.0.0