If we have 1000 rows were loaded in to datawarehouse and
next day the source have 1010 rows so, how can we loaded
only updated rows into target.
- 6 Answers
- 10312 Views
- Accenture, I also Faced
- E-Mail Answers
Answer Posted / priyank
At mapping level,
SRC --> EXP --> FIL --> TGT
--> LKP_TGT
where
LKP_TGT: The look up on the target tables key columns
EXP:
OUT_UPD --> IIF(LKP_TGT.COL is NOT NULL AND ((LKP_TGT.COL1
<> SRC.COL1) OR (LKP_TGT.COL2 <> SRC.COL2)....,'UPD','INS')
FIL: OUT_UPD --> OUT_UPD='UPD'
| Is This Answer Correct ? | 2 Yes | 0 No |
Post New Answer View All Answers
How an expression transformation differs from aggregator transformation?
rank() over (partition by opt2.dim_plat_site_id, opt2.dim_site_opt_sid order by case when opt2.dm_market_flg in ('Y', 'U') then 1 else 2 end, lkp.contact_rank) as rank1, case opt2.contact_type when 'Buyer' then row_number() over (partition by opt2.dim_plat_site_id, opt2.dim_site_opt_sid, lkp.contact_rank order by has_name_flg desc, ship_to_flg desc , last_order_dt desc) when 'Decision Maker' then row_number() over (partition by opt2.dim_plat_site_id, opt2.dim_site_opt_sid, lkp.contact_rank order by has_name_flg desc , last_quote_dt desc , mailability_score desc , source_ranking desc) when 'Influencer' then row_number() over (partition by opt2.dim_plat_site_id, opt2.dim_site_opt_sid, lkp.contact_rank order by has_name_flg desc, mailability_score desc, source_ranking desc) when 'Payer' then row_number() over (partition by opt2.dim_plat_site_id, opt2.dim_site_opt_sid, lkp.contact_rank order by has_name_flg desc, mailability_score desc, source_ranking desc) --elu 05/28/2013 else row_number() over (partition by opt2.dim_plat_site_id, opt2.dim_site_opt_sid, lkp.contact_rank order by has_name_flg desc, mailability_score desc, source_ranking desc) end rank2 row_number() over (partition by opt3.dim_plat_site_id, opt3.dim_site_opt_sid order by rank1,rank2) as "rank", case when "rank"<= opt3.maximum_value then 'Y' else 'N' end as include_flg
What does command task mean?
What is workflow monitor?
What are the measure objects?
What is native users?
What is sequence generator transformation in informatica?
can i any one explain me realtime healthcare project explanation..for interview .iam new to informatica .thanks in advance.
What is data caches/ index caches?
What are the different versions of informatica?
Slowly changing dimensions, types and where will you use them
can anyone explain me about retail domain project in informatica?
What is resilience time?
What is a filter transformation?
Informatica Server and Client are in different machines. You run a session from the server manager by specifying the source and target databases. It displays an error. You are confident that everything is correct. Then why it is displaying the error?
