Leer y escribir RDDs en Scala

por | Jul 13, 2018 | Big data, Scala, Spark | 0 Comentarios

Leer RDDsscala_logo

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/");

0 comentarios

Enviar un comentario

Tu dirección de correo electrónico no será publicada.