cust_id= unique id
my data flow in job :
2 oracle data base ->join stage ->xfm ->MQ serises plug-in
I am reading two tables and joining by using cust_id and sending data to transformer.my source table1 contains cust_id
as key and in 2nd table the keys are cust_id and cust_transx_number
Each cust_id they are spliting:::
<cust_id=1> |
<dtl1> |
. |
. |
. |
</dtl1> |
<dtl2> |
. | ====> Message 1
. |
. |
</dtl2> |
<dtl3> |
. |
. |
. |
</dtl3>
</cust_id>
<cust_id=2> |
<dtl1> |
. |
. |
. |
</dtl1> |
<dtl2> |
. | ====> Message 2
. |
. |
</dtl2> |
<dtl3> |
. |
. |
. |
</dtl3>
</cust_id>
The output should expecting is :::
cust_dtl::
cust_id cust_tranx_number Upc_id
1 1 1000
1 2 1200
1 3 1500
cust_dtl::
2 1 1900
2 2 2200
2 3 2500
any help will be appreciated.
need a logic in parallel job design
Moderators: chulett, rschirm, roy
-
- Participant
- Posts: 54607
- Joined: Wed Oct 23, 2002 10:52 pm
- Location: Sydney, Australia
- Contact:
-
- Participant
- Posts: 135
- Joined: Tue Aug 14, 2007 4:27 am
- Location: Mumbai
Do SQL join in stead of Join Stage.
Any specific reason you used join stage ?
If any then do sorting on keys before joining ....
If you want to track the rejects... then istead if join do Merge and make "Update link" The Reject link( from which you want to get the rejects...)
Hope it helps...
Any specific reason you used join stage ?
If any then do sorting on keys before joining ....
If you want to track the rejects... then istead if join do Merge and make "Update link" The Reject link( from which you want to get the rejects...)
Hope it helps...
Thanks
Swapnil
"Whenever you find whole world against you just turn around and Lead the world"
Swapnil
"Whenever you find whole world against you just turn around and Lead the world"
-
- Participant
- Posts: 54607
- Joined: Wed Oct 23, 2002 10:52 pm
- Location: Sydney, Australia
- Contact: