Hi guys,
In sequencer job,
we have 3 sources, in that 1st source have some records,
Here requirement is 1st source records are 100 then only run
the job otherwise total job will abort...
How to calculate this. please design the job.
Thanks.
Answer / anil
Hi,
We can do it with one seq job and one parallel job
First create parallel job (p1) that calculates aggregate count. If aggregate count is less than 100 then abort the parallel job
Paralled Job Design(P1)
1. Take the data from source.
2. Add a column generator with column name as Temp and its value as A
3. Add aggregrator stage, where group by column is Temp and calculation is count rows. So after aggregation, count will be calculated and stored in Total Count column.
4. In the transformer, add a constraint for output link to a peak stage saying totalcount < 100 and abort after 1 row.
SO if count is greater than 100, parallel job (P1) is successful, Else failed
Sequence Job
1. Add parallel job(p1) to the sequence and add exception handler and terminator activity stage.
2. After P1 you can create whatever sources you want to as a each parallel job.
3. Add automatically handle failed activities in the sequence job properties
Now if P1 fails, sequence fails else rest will run.
Is This Answer Correct ? | 2 Yes | 0 No |
what is the definitions for Datawarehose and Datamart?
tell me abt Datastage trigger?
hi, 1)totally how many jobs created in ur project 2)what is ur datamart size & Dwh size 3)How secure ur project 4)could u plz tell be about testing process after complete the job will run sucessfully or not in Datastage
How a routine is called in datastage job?
How many types of stage?
what is mapping lookup
1)i put Pharma Project in my Resume..whar are the sources used in my project Generally? 2)how many fact and dimensional tables used? 3)Have u used any Datamarts and measues in fact table? ....plz give the answers...
You enter values in a schema file for RCP and you also entered values in sequential file? which one will it take?
How to create a doccument in datastage?
What are the benefits of datastage?
How to clean the datastage repository?
How can we perform 2nd time extraction of client database without accepting the data which is already loaded in first time extraction?