Changes

Jump to: navigation, search

Telemetry/Custom analysis with spark

4 bytes removed, 16:09, 19 September 2016
name change
import numpy as np
#no computation is performed on the following line!
exponentials sin_values = numsRdd.map(lambda x : np.float(x) / 10).map(lambda x : (x, np.sin(x)))
#now the entire computation graph is evaluated
exponentialssin_values.takeOrdered(5, lambda x : -x[1])
For jumping into working with Spark RDD's, we recommend reading the [https://spark.apache.org/docs/latest/programming-guide.html Spark Programming Guide].
Fbertsch
29
edits
Retrieved from "https://wiki.mozilla.org/Special:MobileDiff/1148244"

Navigation menu