Apache Flink

Docker

• data artisans: Introducing Official Docker Images for Apache Flink

Integrating R

• bitbucket: fastr-flink

Integrating Kafka

• Kafka + Flink: A Practical, How-To Guide

Links

• Apache Flink
• Documentation v.1.4
• Basic API Concepts: Linking with Flink
• Downloads: Maven Dependencies

Building Apache Flink from Source

git clone https://github.com/apache/flink.git
cd flink
mvn clean package -DskipTests # this will take up to 10 minutes

Tests

mvn test -rf :flink-ml_2.11

• Re: flink-ml test

For running a specific test under flink-ml:

mvn test -DwildcardSuites=org.apache.flink.ml.math.BreezeMathSuite BreezeMathSuite

Machine Learning

• Stochastic Outlier Selection SOS
• github: jeroenjanssens/phd-thesis

Dataset

• kaggle: Numenta Anomaly Benchmark (NAB) Dataset and scoring for detecting anomalies in streaming data

Learn

• Sample Project in Scala
• Monitoring Wikipedia Edits
• Building real-time dashboard applications with Apache Flink, Elasticsearch, and Kibana
• Apache Flink Training
• dataArtisans/flink-training-exercises