Leer RDDs

Ejemplo de lectura de RDDs en Scala

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

Escribir RDDs

Ejemplo de escritura de RDDs en Scala

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