diff --git a/pom.xml b/pom.xml index f561bbf..49c1ade 100644 --- a/pom.xml +++ b/pom.xml @@ -36,6 +36,12 @@ Patrik at Bintray http://dl.bintray.com/patriknw/maven + + + gearpump-shaded-repo + Vincent at Bintray + http://dl.bintray.com/fvunicorn/maven + @@ -43,11 +49,13 @@ com.github.intel-hadoop gearpump-core_2.11 ${gearpumpVersion} + provided com.github.intel-hadoop gearpump-streaming_2.11 ${gearpumpVersion} + provided com.github.intel-hadoop @@ -63,6 +71,23 @@ + + maven-assembly-plugin + + + jar-with-dependencies + + + + + make-assembly + package + + single + + + + org.apache.maven.plugins maven-compiler-plugin diff --git a/src/main/java/kafka/Sum.java b/src/main/java/kafka/Sum.java index 9150caa..1a10a0c 100644 --- a/src/main/java/kafka/Sum.java +++ b/src/main/java/kafka/Sum.java @@ -44,7 +44,7 @@ public void onStart(StartTime startTime) { @Override public void onNext(Message message) { - String word = (String)(message.msg()); + String word = (String) (message.msg()); Integer current = wordCount.get(word); if (current == null) { current = 0;