Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
10-20-2021 08:56 AM
I have this:
checkpoint_path = target_path + "checkpoints/"
autoloader_query = (raw_df.writeStream
.format("delta")
.trigger(once=True)
.option("checkpointLocation",checkpoint_path)
.partitionBy("p_ingest_date_utc","p_ingest_hour_utc")
.table("raw_cooked")
)So I have it. And it was working long time.