Learning Apache Apex
by Ananth Gundabattula, Thomas Weise, Munagala V. Ramanath, David Yan, Kenneth Knowles
Dedup
Dedup (de-duplication) is used to remove duplicated from input datasets. Occurrence of duplicates is very common and processing pipelines often need to remove them before transformations, such as aggregation, can be applied as, otherwise, results would be inaccurate. As an example, consider calculating aggregate cost and the possibility of duplicates of the same transaction emitted from the source, which can happen due to various reasons including a message transport with non-transactional producer.
Duplicates are a fact for processing pipelines to deal with and most of the times it is necessary to discard them. The purpose of the Dedup operator is to identify and remove or redirect duplicate data:
The preceding diagram shows how ...
Become an O’Reilly member and get unlimited access to this title plus top books and audiobooks from O’Reilly and nearly 200 top publishers, thousands of courses curated by job role, 150+ live events each month,
and much more.
Read now
Unlock full access