val numStreams = 4
val kafkaStreams = (1 to numStreams).map { i => KafkaUtils.createStream(...)
}
In a Java in a for loop you will create four streams using
KafkaUtils.createStream() so that each receiver will run in different
threads
for more information please visit
http://spark.apache.org/doc
In spark, every action (foreach, collect etc.) gets converted into a spark
job and jobs are executed sequentially.
You may want to refactor your code in calculateUseCase? to just run
transformations (map, flatmap) and call a single action in the end.
On Sun, Aug 16, 2015 at 3:19 PM, mohanaugust
