A flat file contains 200 records. I want to load first 50
records at first time running the job, second 50 records at
second time running and so on, how u can develop this job?
Answer Posted / subhash
1st Way:
1. Add 'row number' column in Seq File stage, so that each
record has a number associated with it.
2. Add a job param with which we can provide the number of
record from where we want to run the job. We can pass this
either using Sequence Start LOOP(List type variables-
50,100,150,200) or by shell script.
3. In the tfm, use a stage variable to run only from the
record number till 50 records by counting each record.
2nd way:
Design the job like this:
1. Add 'row number' column in Seq File stage, so that each
record has a number associated with it.
2. Use filter stage and write the conditions like this:
a. row number column<=50(in 1st link to load the records
in target file/database)
b. row number column>50 (in 2nd link to load the records
in the file with the same name as input file name, in
overwrite mode)
So, first time when your job runs first 50 records will be
loaded in the target and same time the input file records
are overwritten with records next first 50 records i.e. 51
to 200.
2nd time when your job runs first 50 records(i.e. 51-100)
will be loaded in the target and same time the input file
records are overwritten with records next first 50 records
i.e. 101 to 200.
And so on, all 50-50 records will be loaded in each run to
the target
Is This Answer Correct ? | 8 Yes | 1 No |
Post New Answer View All Answers
What is the differentiate between data file and descriptor file?
How to implement complex jobs in data stage?
how can we create rank using datastage?what is the meaning of rank?
Can you explain engine tier in information server?
On which Dimension Table you implemented SCD Type in your Project
Explain how a source file is populated?
What all the types of jobs you developed?
What is the difference between operational data stage (ods) and data warehouse?
I have a few records just I want to store data in to targets cycling way how?
What is a folder? Difference types of stages?
What is the difference between datastage and datastage tx?
Can you explain tagbatch restructure operator?
how many rows sorted in sort stage by default in server jobs
Define Data Stage?
table actions available in oracle connector?