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 Posted / 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



Post New Answer       View All Answers


Please Help Members By Posting Answers For Below Questions

Which is the best institute in Hyderabad to learn OBIEE and DataStage?Please tell me faculty name also

2749


How do u convert the columns to rows in datastage?

694


what is the difference between == and eq in UNIX shell scripting?

979


If you want to use the same piece of code in different jobs, how will you achieve it?

644


Difference between in process and inter process?

704






What are the components of ascential data stage?

655


Hi, what is use of Macros,functions and Routines..? At what situation you are used. If you know the answer please explain it. Thanks.

1624


How one source columns or rows to be loaded in to two different tables?

668


What are the benefits of datastage?

732


What are orabulk and bcp stages?

653


What is the difference between passive stage and active stage?

828


what are the errors,warnings in datastage

2157


in oracle target stage when we use load option and when we use upsert option?

1759


What is developer responsibilities in UAT (user acceptance testing and Post implementation phase?

1640


How can you write parallel routines in datastage PX?

622