spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Eduardo Costa Alfaia <e.costaalf...@unibs.it>
Subject Error Compiling
Date Sat, 31 Jan 2015 00:00:04 GMT
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