Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
05-10-2023 06:21 AM
Let's try the following :
cloudfile_options = {
"cloudFiles.format": “json”,
"cloudFiles.schemaLocation": "<path_to_schema_checkpoints_location>",
"cloudFiles.inferColumnTypes":"true"
}
spark.readStream.format("cloudFiles").options(**cloudfile_options).load("<path_to_source_data>")