Forum Discussion
Thank manichandana_ch . This solution worked for me. I have a question that may extend beyond the current topic. How should I design the pipeline to accommodate incremental loads?
- manichandana_ch3 years agoNew Contributor III
Hi Roger667
After getting the data from SF read snap, you can probably take a copy and get the max value of lastmodified date or any audit date column and store it in a file or config table if any. Then, before the SF read, you can read the file/table and get the lastmodifieddate value. Then, in the SF read snap you can add a filter to get the records greater than the lastmodified date.
This is the expression added in where clause of SF read, where $lastmodifieddate is coming from file/table before SF read snap. In case you prefer using file, you can store the file in local sldb or any location that is available to you.
Hope this helps !
Thanks!