Intellipaat Back

Explore Courses Blog Tutorials Interview Questions
0 votes
in Big Data Hadoop & Spark by (11.4k points)

I have an application, which sends data to AWS Kinesis Firehose and this writes the data into my S3 bucket. Firehose uses "yyyy/MM/dd/HH" format to write the files.

Like in this sample S3 path:


Now I have a Spark application written in Scala, where I need to read data from a specific time period. I have start and end dates. The data is in JSON format and that's why I use not sc.textFile().

How can I read the data quickly and efficiently?

1 Answer

0 votes
by (32.3k points)

Have a look at the DataFrameReader API  and you'll notice that there is a  .json(paths: String*) method. This will easily solve your problem. Just build a collection of the paths you want, with globs of not, as you prefer, and then call the method, e.g.,

val paths: Seq[String] = ...

val df = _*)

Related questions

Browse Categories