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 <[email protected]>: > 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. >
