Flunx - Flux language on Flink engine
The mapping from a Flux specification is yet to be completed, this is a naive implementation.
To run a simple example, download Flink binaries and:
$ ./bin/flux compile @./queries/gen.flux > gen.spec
$ mvn package
$ ./flink-1.6.1/bin/flink run ./target/flunx.jar --spec ./gen.spec
NOTE: It seems that running those commands prevents from seeing the output of the job.
In order to see it, run the job inside an IDE of your choice.