Lectura y escritura de RDDs en Scala

Lectura de RDDs

val rdd2 = sc.textFile("hdfs:///mitabla_hdfs/")
rdd2.collect()
res: Array[String] = Array(1, 2, 3, 4, 5, 6, 7, 8, 9)

 

Escritura de RDDs

val rdd = sc.parallelize(List(1,2,3,4,5,6,7,8,9))
rdd.saveAsTextFile ("hdfs:///mitabla_hdfs/");

Autor: Diego Calvo