flink-file-source

Apache Flink® is a framework and distributed processing engine for stateful computations over unbounded and bounded data streams.
This open source project contains a Source operator that allow to retrieval file content and handling mutations. You must provide a class that represent the content file so that the operator can return a typed stream.

Maven Repository

Flink file source release are available from Maven Central. Snapshot builds are distributed using OSS Sonatype

Quick Installation

If you are using Maven you can add the flink-file-source by adding the following XML to your pom.xml file:

<dependency>
  <groupId>it.fabricalab.streaming</groupId>
  <artifactId>flink-file-source</artifactId>
  <version>1.1.0</version>
</dependency>

Documentation

All the documentation is available on the wiki pages.

Disclaimer

Apache Flink, Flink®, Apache®, the squirrel logo, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.