Lectura de ficheros externos en RDD
rdd_file = sc.textFile("/home/file.txt")Escritura de RDD en un directorio
rdd_file.saveAsTextFile("/dbfs/FileStore/tables/RDD_dir")Lectura y escritura de ficheros Apache Spark en Python
rdd_file = sc.textFile("/home/file.txt")rdd_file.saveAsTextFile("/dbfs/FileStore/tables/RDD_dir")
0 Comentarios