This quick start will walk you through executing your first Gearpump pipeline to run WordCount written in Stream DSL.
Set up development environment
- Download and install Java Development Kit(JDK) 1.8. Verify that JAVA_HOME is set and points to your JDK installation.
- Download and install sbt by following sbt's installation guide for your specific operating system.
Run WordCount
-
Run WordCount example with sbt
sbt "project gearpump-examples-wordcount" run
-
Select the third main class in the sbt console
Multiple main classes detected, select one to run: [1] io.gearpump.streaming.examples.wordcount.WordCount [2] io.gearpump.streaming.examples.wordcount.dsl.WindowedWordCount [3] io.gearpump.streaming.examples.wordcount.dsl.WordCount Enter number: 3
If everything goes fine, the following output is expected
(is,1)(bingo!!,2)(a,1)(good,1)(This,1)(start,,1)