Gearpump Java Examples

Raheem_D_ — Sun, 27 Sep 2015 17:26:32 GMT

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!

This repository holds some

steve_m_1 — Sun, 11 Oct 2015 08:19:36 GMT

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}

topic This repository holds some in Software Archive

Gearpump Java Examples

This repository holds some