Skip to content
Branch: master
Find file History
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Type Name Latest commit message Commit time
Failed to load latest commit information.

Small WordCount example on how to write a Flink program in Clojure.

Steps to run this code with lein:

  1. execute lein run

Steps to run this code with bin/flink:

  1. run mvn -DskipTests clean package
  2. execute with bin/flink run <path-to>/flink-clojure/target/WordCount-Clojure.jar

You can also run this example within Intellij IDEA (with Cursive plugin).

You can’t perform that action at this time.