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
