I have the following requirement I am developing Seq/parallel jobs.
Code: Select all
Dep_Group logic --Per group limit -5000 employees (records with Dep_Indicator BCF,DS)
Non_Dep_Group --No grouping required -Assign default '0' (records with Non_Dep_Indicator DW)
Code: Select all
Area|Employee_count|Deparment|Dep_DSC_INDICATOR|Dep_GROUP|NON_Dep_DSC_INDICATOR|NON_Dep_GROUP
1|2500|10|BCF,DS|1||
2|2500|10|BCF,DS|1||
3|2500|10|DS|2|DW|0
4|2500|10|BCF,DS|2||
5|2500|10|BCF,DS|3||
6|2500|10|DS|3|DW|0
Code: Select all
Dep_DSC_Deparment_GROUP.txt|ExpectedAreas in each file
BCF_10_1.txt (1,2)
BCF_10_2.txt (4)
BCF_10_3.txt (5)
DS_10_1.txt (1,2)
DS_10_2.txt (3,4)
DS_10_3.txt (5,6)
DW_10_0.txt (3,6)
Code: Select all
uservariable_group_ctr (max_group counter) -->start loop --->split job (parallel job) -->end loop -exit loop
Code: Select all
input file --xfm -->output file
Please suggest me some ideas to implement.
Thank you