Submitted by @stodoroska from Interworks
Delta Load from a staging to Oracle DWH table. Pipeline should detect if the record is an Update, Delete or Insert according to a flag in the Mlog table which is Oracle native table for storing logs of transactions. According to those flags and the id of the records, the pipeline is deciding which action it should perform, update, delete or insert.
Screenshot of pipeline
Configuration
In each of the Snaps you should define your respective queries and DB accounts.
Sources: Oracle DB table
Targets: Oracle DB table
Snaps used: Oracle Execute, Router, Mapper, Aggregate, Unique, Join, Copy
Downloads
Attach pipelines and any necessary resources such as expression libraries or source files.
Diane Miller
