flink-operator-library

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>