The library provides a set of Apache Flink operators and supporting utilities. Please visit the wiki to learn more about the implemented components. Amongst them you will find
- a JSON based content filter
- an integration with flink-spector to allow testing of JSON based operators
- JSON processing utilities
- an abstract runtime foundation for streaming applications to speed up development
- a selector implementation to extract keys from JSON documents
- a JSON to character separated string converter
- an operator to insert static content into existing JSON documents
- a window-based JSON content aggregator
- some JSON content mappers
To integrate the library with maven based projects, please add these sections:
<repositories>
<repository>
<id>otto-bintray</id>
<url>https://dl.bintray.com/ottogroup/maven</url>
</repository>
</repositories>
For use with Scala v2.10
<dependencies>
<dependency>
<groupId>com.ottogroup.bi.streaming</groupId>
<artifactId>flink-operator-library</artifactId>
<version>0.3.4_2.10</version>
</dependency>
</dependencies>
For use with Scala v2.11
<dependencies>
<dependency>
<groupId>com.ottogroup.bi.streaming</groupId>
<artifactId>flink-operator-library</artifactId>
<version>0.3.4_2.11</version>
</dependency>
</dependencies>