Somehow the scala compiler is not able to infer the types from _ + _
Try
reduceByKeyAndWindow((x: Int, y: Int) = x + y, Seconds(30), Seconds(10))
TD
2014-02-06 Eduardo Costa Alfaia e.costaalf...@unibs.it:
Hi Guys,
I am getting this error when I compile NetworkWordCount.scala:
nfo] Compiling 1 Scala source to
/opt/unibs_test/incubator-spark-tdas/examples/target/scala-2.10/classes...
[error]
/opt/unibs_test/incubator-spark-tdas/examples/src/main/scala/org/apache/spark/streaming/examples/NetworkWordCount.scala:63:
missing parameter type for expanded function ((x$2, x$3) = x$2.$plus(x$3))
[error] val wordCounts = words.map(x = (x, 1)).reduceByKeyAndWindow(_ +
_, Seconds(30), Seconds(10))
[error] ^
[error] one error found
[error] (examples/compile:compile) Compilation failed
[error] Total time: 16 s, completed 07-Feb-2014 01:13:21
Could anyone help me?
Thanks
--
INFORMATIVA SUL TRATTAMENTO DEI DATI PERSONALI
I dati utilizzati per l'invio del presente messaggio sono trattati
dall'Università degli Studi di Brescia esclusivamente per finalità
istituzionali. Informazioni più dettagliate anche in ordine ai diritti
dell'interessato sono riposte nell'informativa generale e nelle notizie
pubblicate sul sito web dell'Ateneo nella sezione Privacy.
Il contenuto di questo messaggio è rivolto unicamente alle persona cui
è indirizzato e può contenere informazioni la cui riservatezza è
tutelata legalmente. Ne sono vietati la riproduzione, la diffusione e l'uso
in mancanza di autorizzazione del destinatario. Qualora il messaggio
fosse pervenuto per errore, preghiamo di eliminarlo.
