6) my sorce
d1
d2
d1
d2
d1
d3
d2
d1
my target
tartget
1 d1
2 d1
3 d1
4 d1
target2
1 d2
2 d2
3 d3
Target 3
1 d3
Can any body send me answer this is argent requierment
Answers were Sorted based on User's Feedback
1. SRC--->FILTER---->TGT1,TGT2,TGT3
In source query,
SELECT COL1,
RANK() OVER(PARTITION BY COL1 ORDER BY COL1) SNO
FROM TABLE
in filter,
col1='d1'------>TGT1
col1='d2'------>TGT2
col1='d3'------>TGT3
2. SRC---->TFM---->TGT1,TGT2,TGT3
in TFM, do the HASH partitioning on col1 and use the stage
varibles as below:
if col1 =prevCol then SV1=S1+1
else SV1=1
prevCol---->col1
In the link constraints:
TGT1 link, COL1='d1'
map SV1, COL1 to the tgt.
TGT2 link, COL1='d2'
map SV1, COL1 to the tgt.
TGT3 link, COL1='d3'
map SV1, COL1 to the tgt.
| Is This Answer Correct ? | 11 Yes | 0 No |
Answer / ankit gosain
Hi,
The solution to the problem can be achieved by the below
job structure & settings:
Source---->SortStage---->Transformer---->Tgt1,Tgt2,Tgt3
1. In Sort Stage, sort in assending mode w.r.t. source
column (say col1) & Create a change key column (say
ChangeKey).
2. In Transformer stage, create a stage variable (say
count) & it's derivation would be:
if ChangeKey=1 then 1 else count+1
3. Constraint for Tgt1 => col1=d1
Constraint for Tgt2 => col1=d2
select otherwise constraint for Tgt3.
Cheers,
Ankit :)
| Is This Answer Correct ? | 6 Yes | 1 No |
Answer / srinivas
Hii guys use following stages to get output
sequecial file->copy->aggregator and Joinstage then use filter to get required output
by using copy stage take two links one for aggregator and other for Join then you will get
required output
| Is This Answer Correct ? | 1 Yes | 0 No |
hi my source is:: empno,deptno,salary 1, 10, 3.5 2, 20, 8 2, 10, 4.5 1, 30, 5 3, 10, 6 3, 20, 4 1, 20, 9 then target should be in below form... empno,max(salary),min(salary),deptno 1, 9, 3.5, 20 2, 8, 4.5, 20 3, 6, 4, 10 can anyone give data flow in data stage for the above scenario.... thanks in advance...
If I make any changes in the parallel job,do I need to implement the changes in the sequencer job,else the changes will be reflected automatically
How can u execute the sql query through unix? What is the Primary key for Dimension table? what is the primary key for Fact table?
what is the difference between 7.1,7.5.2,8.1 versions in datastage?
What is the Environment Variable need to Set to TRIM in Project Level?(In transfermer, we TRIM function but I need to impliment this project level using Environment variable)
Difference between sequential file and data set?
I am having the 2 source files A and B and I want to get the output as, the data which is in file A and which doesn't in file B to a target 1 and which is in file B and which doesn't in file A to a target 2?
Create a job to load all unique products in one table and the duplicate rows in to another table. The first table should contain the following output A D The second target should contain the following output B B B C C Q2. Create a job to load each product once into one table and the remaining products which are duplicated into another table. The first table should contain the following output A B C D The second table should contain the following output B B C
i 10 jobs first two jobs are runing in 2nodes,next 2 jobs are running in 4 nodes, next 4 jobs are running in 6 nodes and the remaining jobs are running on 10 nodes. how to change the node configuration?
What are constraints and derivations?
1)s.key generate 1 to 700 records today. tomorrow another 400 will updated how to update the records using s.key generator? 2)source is like :-- DB --> T/F stage1 --> seq1file T/f 1 is linking with T/F2 ---> seq 2 how to load the data? in source i given some conditions those r going in seq1. The another data will going to seq2 how to do this ?
how to find no.of records in sequntial file itself?