Can you take a look at:
./examples/scala-2.10/src/main/java/org/apache/spark/examples/streaming/JavaKafkaWordCount.java
./external/kafka/src/test/java/org/apache/spark/streaming/kafka/JavaKafkaStreamSuite.java
Cheers
On Sat, Feb 7, 2015 at 9:45 AM, Eduardo Costa Alfaia <e.costaalf...@unibs.it
> wrote:
> Hi Guys,
>
> How could I doing in Java the code scala below?
>
> val KafkaDStreams = (1 to numStreams) map {_ =>
> KafkaUtils.createStream[String, String, StringDecoder,
> StringDecoder](ssc, kafkaParams, topicMap,storageLevel =
> StorageLevel.MEMORY_ONLY).map(_._2)
>
> }
> val unifiedStream = ssc.union(KafkaDStreams)
> val sparkProcessingParallelism = 1
> unifiedStream.repartition(sparkProcessingParallelism)
>
> Thanks Guys
>
> Informativa sulla Privacy: http://www.unibs.it/node/8155
