cancel
Showing results forย 
Search instead forย 
Did you mean:ย 
Data Engineering
cancel
Showing results forย 
Search instead forย 
Did you mean:ย 

Is it possible to write single Spark stream to 2 different Delta tables? Recommendations around that?

Anonymous
Not applicable
 
1 ACCEPTED SOLUTION

Accepted Solutions

Ryan_Chynoweth
Honored Contributor III

In this scenario, the best option would be to have a single readStream reading a source delta table. Since checkpoint logs are controlled when writing to delta tables you would be able to maintain separate logs for each of your writeStreams.

I would recommend storing your checkpoint file in a `_checkpoint` sub-directory in your delta table directory. The "_" will allow spark to ignore it when reading the table and you are able to maintain those checkpoints with the appropriate tables.

View solution in original post

1 REPLY 1

Ryan_Chynoweth
Honored Contributor III

In this scenario, the best option would be to have a single readStream reading a source delta table. Since checkpoint logs are controlled when writing to delta tables you would be able to maintain separate logs for each of your writeStreams.

I would recommend storing your checkpoint file in a `_checkpoint` sub-directory in your delta table directory. The "_" will allow spark to ignore it when reading the table and you are able to maintain those checkpoints with the appropriate tables.

Welcome to Databricks Community: Lets learn, network and celebrate together

Join our fast-growing data practitioner and expert community of 80K+ members, ready to discover, help and collaborate together while making meaningful connections. 

Click here to register and join today! 

Engage in exciting technical discussions, join a group with your peers and meet our Featured Members.