How to read multiple text files into a single RDD?

Question

I want to read a bunch of text files from a hdfs location and perform mapping on it in an iteration using spark.

JavaRDD<String> records = ctx.textFile(args[1], 1); is capable of reading only one file at a time.

I want to read more than one file and process them as a single RDD. How?

Answer 1

Try to create all the RDD first and then put them all into a single RDD.

val sc = new SparkContext(...)

val r1 = sc.textFile("xxx1")

val r2 = sc.textFile("xxx2")

...

val rdds = Seq(r1, r2, ...)

val FinalRdd = sc.union(rdds)

Now the FinalRdd is the RDD with all files.

If you want more information regarding Spark, refer the following video: