Apache Flink tutorial code.
Apache Flink tutorial code.
Using the following techniques:
Flink features:
Gradle Kotlin DSL features:
Run:
$ gradle clean build
$ gradle run --args="--input ../ml-latest-small/movies.csv --output filter-output"
$ gradle averageRating --args="--movies ../ml-latest-small/movies.csv --ratings ../ml-latest-small/ratings.csv"
Datasets:
Movielens data downloaded from:
https://grouplens.org/datasets/movielens/