On Wed, Jan 15, 2014 at 6:01 AM, Eduardo Costa Alfaia
e.costaalf...@studenti.unibs.it wrote:
Hi Guys,
I did some changes in JavaNetworkWordCount for my researches in streaming
process and I have added to the code the following lines in red:
ssc1.checkpoint(hdfs://computer22:54310
2014/1/20 Eduardo Costa Alfaia e.costaalf...@studenti.unibs.it
Hi guys,
Somebody help me, Where do I get change the print() function to print more
than 10 lines in screen? Is there a manner to print the count total of all
words in a batch?
Best Regards
--
---
INFORMATIVA SUL
= rdd.take(n)
println(First N elements = + firstN)
// Count the number of elements in each batch
println(RDD has + rdd.count() + elements)
})
Alternatively, just for printing the counts, you can also do
yourDStream.count.print()
Hope this helps!
TD
2014/1/20 Eduardo Costa
can also do
yourDStream.count.print()
Hope this helps!
TD
2014/1/20 Eduardo Costa Alfaia e.costaalf...@studenti.unibs.it
Hi guys,
Somebody help me, Where do I get change the print() function to print
more
than 10 lines in screen? Is there a manner
Hi Guys,
I'm not very good like java programmer, so anybody could me help with this
code piece from JavaNetworkWordcount:
JavaPairDStreamString, Integer wordCounts = words.map(
new PairFunctionString, String, Integer() {
@Override
public Tuple2String, Integer call(String
on replication if you want
fault-tolerance.
TD
On Mon, Feb 3, 2014 at 3:19 PM, Eduardo Costa Alfaia e.costaalf...@unibs.it
wrote:
Hi Tathagata,
You were right when you have said for me to use scala against java, scala
is very easy. I have implemented that code you have given (in bold
