spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Tathagata Das <tathagata.das1...@gmail.com>
Subject Re: Compiling NetworkWordCount scala code
Date Fri, 07 Feb 2014 08:23:31 GMT
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.costaalfaia@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.
>

Mime
View raw message