Skip to content

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

License

Notifications You must be signed in to change notification settings

aws/aws-kinesisanalytics-runtime

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

17 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

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.

About

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

Resources

License

Code of conduct

Security policy

Stars

Watchers

Forks

Packages

No packages published

Contributors 4

  •  
  •  
  •  
  •  

Languages