spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Akhil Das <ak...@sigmoidanalytics.com>
Subject Re: Error Compiling
Date Sat, 31 Jan 2015 07:48:20 GMT
This is how i do it:

val tmp = test.map(x => (x, 1L)).reduceByWindow({ case ((word1, count1),
(word2, count2)) => (word1 + " " + word2, count1 + count2)}, Seconds(10),
Seconds(10))


In your case you are actually having a type mismatch:

[image: Inline image 1]



Thanks
Best Regards

On Sat, Jan 31, 2015 at 5:30 AM, Eduardo Costa Alfaia <
e.costaalfaia@unibs.it> wrote:

> Hi Guys,
>
> some idea how solve this error
>
> [error]
> /sata_disk/workspace/spark-1.1.1/examples/src/main/scala/org/apache/spark/examples/streaming/KafkaWordCount.scala:76:
> missing parameter type for expanded function ((x$6, x$7) => x$6.$plus(x$7))
>
> [error]     val wordCounts = words.map(x => (x, 1L)).reduceByWindow(_ +
> _, _ - _, Minutes(1), Seconds(2), 2)
>
> Thanks
>
> Informativa sulla Privacy: http://www.unibs.it/node/8155

Mime
View raw message