Calcular la media móvil simple (3 periodos)
Calcula la media móvil a partir de una ventana temporal de 3 periodos
import org.apache.spark.mllib.rdd.RDDFunctions._ val a = List(1,5,6,7,9,10,12,14) val b = sc.parallelize(a) .sliding(3) .map(curSlice => (curSlice.sum / curSlice.size)) b.collect() res a: List[Int] = List(1, 5, 6, 7, 9, 10, 12, 14) res b: Array[Int] = Array(4, 6, 7, 8, 10, 12)
0 comentarios