Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
03-30-2023 03:22 AM
Still getting all 1000 files.
(spark.readStream.format("delta").option("maxFilesPerTrigger", 100).load(silver_path)
.writeStream
.option("checkpointLocation", gold_checkpoint_path)
.trigger(once=True)
.foreachBatch(foreachBatchFunction)
.start()
.awaitTermination()
)