Solved
Forum Discussion
bojanvelevski
4 years agoValued Contributor
In order to exclude duplicates, you’ll have to use a Diff mechanism. Practically, when get records that are updated in the last 48 hours, you need to compare them with Salesforce records added in the last 48 hours by using a Diff snap.
darshthakkar
4 years agoValued Contributor
Thank you @bojanvelevski, cheked Diff
snap, wasn’t aware of this up until now. It suggests that the input streams should be sorted, I will have to use a sorter as my entire pipeline was unsorted.
- bojanvelevski4 years agoValued Contributor
Yes @darshthakkar, you’ll have to sort the streaming data on the same field you’ll differentiate on.