These functions operate on an RDD of Double which is not what you have, so no this is not a way to use DoubleRDDFunctions. See earlier in the thread for canonical solutions. On Sep 12, 2014 8:06 AM, "rzykov" <rzy...@gmail.com> wrote:
> Tried this: > > ordersRDD.join(ordersRDD).map{case((partnerid, itemid),((matchedida, > pricea), (matchedidb, priceb))) => ((matchedida, matchedidb), (if(priceb > > 0) (pricea/priceb).toDouble else 0.toDouble))} > .groupByKey > .values.stats > .first > > Error: > <console>:37: error: could not find implicit value for parameter num: > Numeric[Iterable[Double]] > .values.stats > > > > > > -- > View this message in context: > http://apache-spark-user-list.1001560.n3.nabble.com/Computing-mean-and-standard-deviation-by-key-tp11192p14065.html > Sent from the Apache Spark User List mailing list archive at Nabble.com. > > --------------------------------------------------------------------- > To unsubscribe, e-mail: user-unsubscr...@spark.apache.org > For additional commands, e-mail: user-h...@spark.apache.org > >