Thank you very much Sourav
BR
Em 3/26/14, 17:29, Sourav Chandra escreveu:
def print() {
def foreachFunc = (rdd: RDD[T], time: Time) => {
val total = rdd.collect().toList
println ("---")
println ("Time: " + time)
println ("
This works just fine without any compilation error:
def print() {
def foreachFunc = (rdd: RDD[T], time: Time) => {
val total = rdd.collect().toList
println ("---")
println ("Time: " + time)
println ("-
Thanks Guys for reply, but I have found this piece of code in streaming:
def print() {
585 def foreachFunc = (rdd: RDD[T], time: Time) => {
586 //val first11 = rdd.take(11)
587 //val first100 = rdd.take(100)
588 val total = rdd.collect()
589 println ("---
You can extend DStream and override print() method. Then you can create
your own DSTream extending from this.
On Tue, Mar 25, 2014 at 6:07 PM, Eduardo Costa Alfaia <
e.costaalf...@unibs.it> wrote:
> Hi Guys,
> I think that I already did this question, but I don't remember if anyone
> has answere
Hi Guys,
I think that I already did this question, but I don't remember if anyone
has answered me. I would like changing in the function print() the
quantity of words and the frequency number that are sent to driver's
screen. The default value is 10.
Anyone could help me with this?
Best Rega
