This quick start will walk you through executing your first Gearpump pipeline to run WordCount written in Stream DSL.

Set up development environment

  1. Download and install Java Development Kit(JDK) 1.8. Verify that JAVA_HOME is set and points to your JDK installation.
  2. Download and install sbt by following sbt's installation guide for your specific operating system.

Run WordCount

  1. Run WordCount example with sbt

    sbt "project gearpump-examples-wordcount" run
  2. 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)