Interested to Buy Any Domain ? << Click Here >> for more details...
Answer Posted / anonymous
we can implement scd2 using the below scenario in abinitio:-
1. take 2 tables as your input first would be your today's file that is in0 second be your previous file that would be in1.
2. take the inner join of both the tables on the matching key say cust_id, and in the out port of the dml make it embedded and do the naming convention by adding the suffix _new for the today's file and _old for the prev day file data records so to make it easier to understand the data fields.
3. In the join components, unused 0 will give you inserted records(that would come from today's file), and unused 1(that would come from yesterday's file) will give you deleted records.
4. take a reformat connecting the join output port and check:
if ( _new != _old) (these are the suffix we have given in the dml output port coming from the join component), force error it from the reject port of reformat those will be your updated records and you will get the unchanged records from the output port of reformat.
5. combine all the inserted records from join unused 0, updated records from reject port of reformat and unchanged records from out port of reformat and load all of them into the delta table.
this would complete the scd type 2 execution in abinitio.
| Is This Answer Correct ? | 16 Yes | 0 No |
Post New Answer View All Answers
Describe the evaluation of parameters order in ab initio?
What are differences between different gde versions(1.10,1.11,1.12,1.13and 1.15)?what are differences between different versions of co-op?
Can anyone give me an example of realtime start script in the graph?
How can a graph be run infinitely?
How can you export a component’s internal parameters ?
What do you know about abinitio?
Input A 100 NUll A NUll 200 B 100 Null B Null 300 Output A 100 200 B 100 300 Do this using Ab initio
What are the different types of parallelism used in abinitio?
Dear all, Please send me the ab initio pdfs and faqs i need... my mail id is rrajesh.intel@gmail.com
What are the differences between different versions of co-op?
What is the use of aggregation when we have rollup as we know rollup component in abinitio is used to summarize a group of data record? Then where we will use aggregation?
how to insert/update a csv file by comparing it with another csv file?
What are the primary keys and foreign keys?
Do you think effective communication is necessary for data processing?
Whenever we load data into oracle table from staging table using exchange partition...then I read somewhere that data actually doesn't move in this and this command only reset the pointer in the data dictionary...so if data doesn't move then how data is loaded into the main table ? I mean wat is the point of pointer update in data dictionary?
