Gearpump Java Examples

[Raheem_D_]

I am trying to get the gearpump java examples, (2.11.5-0.6.1.4), to work.  Has anyone had any luck building them.  So far, I have figured out I need to:

1.  Build the gearpump-shaded-repo project

2.  Tried building the java example as is and deploying.  Got some class not found errors

3.  Tried building a shaded jar out of the java examples, but got an NPE

Anyone had any luck?

Thanks!

[steve_m_1]

This repository holds some common gearpump usage patterns with Java.

The examples include:

word count -- simple Java app that shows the structure of gearpump app
Kafka -> Kafka pipeline -- very simple example that shows how to read and write from Kafka topics
Kafka -> HBase pipeline -- how to read from Kafka topic, how to write to HBase

To build the examples run:

mvn package

After build, there is a jar under target/streaming-java-template-$VERSION.jar.

Start the gearpump cluster (0.4)

a) Download from http://www.gearpump.io/site/downloads/

b) After extraction, start the local cluster

bin/local
c) Start the UI server

bin/services
Submit the jar

bin/gear app -jar path/to/streaming-java-template-$VERSION.jar <app mainclass with package> 
for example:

bin/gear app -jar target/streaming-java-template-$VERSION.jar javatemplate.WordCount 
Check the UI http://127.0.0.1:8090/

NOTE:

Please use Java7 to run the cluster.

You can set the ENV JAVA_HOME.

On windows: set JAVA_HOME={path_to_java_7}

On Linux export JAVA_HOME={path_to_java_7}