AWS Kinesis Analytics Java Flink Runtime

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

Лицензия

Лицензия

Категории

Категории

AWS Контейнер PaaS Providers
Группа

Группа

com.amazonaws
Идентификатор

Идентификатор

aws-kinesisanalytics-runtime
Последняя версия

Последняя версия

1.2.0
Дата

Дата

Тип

Тип

jar
Описание

Описание

AWS Kinesis Analytics Java Flink Runtime
This library contains the Kinesis Analytics Java stream processing runtime configuration classes.
Ссылка на сайт

Ссылка на сайт

https://aws.amazon.com/kinesis/data-analytics/
Система контроля версий

Система контроля версий

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

Скачать aws-kinesisanalytics-runtime

Как подключить последнюю версию

<!-- 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"]

Зависимости

provided (2)

Идентификатор библиотеки Тип Версия
org.apache.flink : flink-core jar 1.8.3
org.apache.flink : flink-shaded-jackson jar 2.7.9-4.0

test (2)

Идентификатор библиотеки Тип Версия
junit : junit jar 4.13
org.assertj : assertj-core jar 3.16.1

Модули Проекта

Данный проект не имеет модулей.

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

Версии библиотеки

Версия
1.2.0
1.1.0
1.0.1
1.0.0