not legal to set a reducer to be the same as a key field

Post questions here relative to DataStage Enterprise/PX Edition for such areas as Parallel job design, Parallel datasets, BuildOps, Wrappers, etc.

Moderators: chulett, rschirm, roy

Post Reply
hsahay
Premium Member
Premium Member
Posts: 175
Joined: Wed Mar 21, 2007 9:35 am

not legal to set a reducer to be the same as a key field

Post by hsahay »

Situation:
I have 3 int. columns and 1 amt. decimal(16,5) column.
Pty_Id, Stm_No, Doc_No and Amt.

I am taking a count of records and a sum based on those 3 int. column grouping keys.

Output is a fixed-width text file with all cols. as char.
Pty_Id, Stm_No, Doc_No, Rec_Count and Tot_Amt

Error:
Aggr_ForPayDirHdrFtr: Error when checking operator: It is not legal to set
a reducer (PTY_ID) to be the same as a key field,
when the type of that field (int32) is not a double.

I tried keeping Pty_Id col. both int and double. With Pty_Id as int col. I am getting the above error.

With Pty_Id as double it works but I am getting wrong output while fixing the fixed width columns to char. Str('0', 9-Len(LinkAggre1.Pty_Id) : LinkAggre1.Pty_Id With double col. the output is,
9.90107e+0 if Pty_id is 1234567.

It should give me 001234567 (9 chars)

Can you pls. help me in this?
Top
ray.wurlod
Participant
Posts: 54607
Joined: Wed Oct 23, 2002 10:52 pm
Location: Sydney, Australia
Contact:
Contact ray.wurlod

Post by ray.wurlod »

Can you please post that part of the generated osh that pertains to the Aggregator stage, between the lines of asterisks, so we can check your work?
IBM Software Services Group
Any contribution to this forum is my own opinion and does not necessarily reflect any position that IBM may hold.
Top
hsahay
Premium Member
Premium Member
Posts: 175
Joined: Wed Mar 21, 2007 9:35 am

Post by hsahay »

ray.wurlod wrote:Can you please post that part of the generated osh that pertains to the Aggregator stage, between the lines of asterisks, so we can check your work?
Thanks Ray for an instant reply but the job log is too huge to put in this forum... I am posting few of the lines before and after that error here

Copy_of_AFMBR_SQL: Column PREM_FNL_CR floating point decimal not fully supported. Adjusting scale.

main_program: APT_SortedGroup2Operator::describeOperator nkeys: 3

Aggr_ForPayDirHdrFtr: Error when checking operator: It is not legal to set a reducer (PTY_ID) to be the same as a key field,
when the type of that field (int32) is not a double.

STM_CAT_GRP_AFMBR: When checking operator: When binding output interface field "STM_CAT_GRP_ID" to field "STM_CAT_GRP_ID": Converting nullable source to non-nullable result; fatal runtime error could occur (use modify operator to specify value to which null should be converted)

STM_CAT_GRP_AFMBR: When checking operator: When binding output interface field "STM_CAT_GRP_CDE" to field "STM_CAT_GRP_CDE": Implicit conversion; from source type "decimal[38,10]" to result type "int32": Possible range/precision limitation

Pls. Let me know if this is good enough.

Thanks in advance...
Top
ray.wurlod
Participant
Posts: 54607
Joined: Wed Oct 23, 2002 10:52 pm
Location: Sydney, Australia
Contact:
Contact ray.wurlod

Post by ray.wurlod »

No. And I did not ask for the job log, I asked for the generated OSH, and only for a portion thereof. You will find this in the job properties, on the Generated OSH tab.
IBM Software Services Group
Any contribution to this forum is my own opinion and does not necessarily reflect any position that IBM may hold.
Top
hsahay
Premium Member
Premium Member
Posts: 175
Joined: Wed Mar 21, 2007 9:35 am

Post by hsahay »

ray.wurlod wrote:No. And I did not ask for the job log, I asked for the generated OSH, and only for a portion thereof. You will find this in the job properties, on the Generated OSH tab.
When I looked for Generated OSH in job property I did not find any Generated OSH Tab. Is there any other way we can get that?
vishal
Top
ray.wurlod
Participant
Posts: 54607
Joined: Wed Oct 23, 2002 10:52 pm
Location: Sydney, Australia
Contact:
Contact ray.wurlod

Post by ray.wurlod »

It's there, but may be disabled (greyed out). In that case you need to enable display of generated OSH using the Administrator client.
IBM Software Services Group
Any contribution to this forum is my own opinion and does not necessarily reflect any position that IBM may hold.
Top
hsahay
Premium Member
Premium Member
Posts: 175
Joined: Wed Mar 21, 2007 9:35 am

Post by hsahay »

ray.wurlod wrote:It's there, but may be disabled (greyed out). In that case you need to enable display of generated OSH using the Administrator client.
I manage to get that thing activated... and here is the OSH

#################################################################
#### STAGE: Lkp_StmCAtGrp_PtyNA
## Operator
lookup
## Operator options
-table
-key MUS_USR_TYP_CDE
-key LKP_NA
-key LKP_LIC_TYP_CDE
-key LKP_CAL_LTR_SUF
-table
-key PAYBL_OWN_PTY_NA_ID
-ifNotFound continue

## General options
[ident('Lkp_StmCAtGrp_PtyNA'); jobmon_ident('Lkp_StmCAtGrp_PtyNA')]
## Inputs
0< 'NullToValues:LnkAfmbr.v'
1< [view (
MUS_USR_TYP_CDE=MUS_USER_TYP_CDE;
LKP_NA=CALL_LTR;
LKP_LIC_TYP_CDE=LIC_TYP_CDE;
LKP_CAL_LTR_SUF=CALL_LTR_SUF;
)] 'STM_CAT_GRP_AFMBR:LkpStmCatGrp.v'
2< [view (
PAYBL_OWN_PTY_NA_ID=PTY_NA_ID;
)] 'PTY_NA:LkpPtyNa.v'
## Outputs
0> [] 'Lkp_StmCAtGrp_PtyNA:LnkSCG_PtyNa.v'
;

#################################################################
#### STAGE: STM_CAT_GRP_AFMBR
## Operator
oraread
## Operator options
-dboptions '{user=[&DB_USER],password=[&DB_PWD]}'
-server '[&DB_SERVER_QA]'
-query 'SELECT STM_CAT_GRP_ID,
NVL(STM_CAT_GRP_CDE,0) STM_CAT_GRP_CDE,
DES,
MUS_USER_TYP_CDE,
NVL(MUS_USER_GRP,\' \') MUS_USER_GRP,
CALL_LTR,
LIC_TYP_CDE,
CALL_LTR_SUF,
STM_SUB_CAT_IND
FROM STM_CAT_GRP_AFMBR'

## General options
[ident('STM_CAT_GRP_AFMBR'); jobmon_ident('STM_CAT_GRP_AFMBR')]
## Outputs
0> [modify (
STM_CAT_GRP_ID:not_nullable int32=STM_CAT_GRP_ID;
STM_CAT_GRP_CDE:nullable int32=STM_CAT_GRP_CDE;
DES:nullable string[max=100]=DES;
MUS_USER_TYP_CDE:nullable string[max=5]=MUS_USER_TYP_CDE;
MUS_USER_GRP:nullable string[max=20]=MUS_USER_GRP;
CALL_LTR:nullable string[max=90]=CALL_LTR;
LIC_TYP_CDE:nullable string[max=4]=LIC_TYP_CDE;
CALL_LTR_SUF:nullable string[max=3]=CALL_LTR_SUF;
STM_SUB_CAT_IND:nullable string[1]=STM_SUB_CAT_IND;
keep
STM_CAT_GRP_ID,STM_CAT_GRP_CDE,DES,MUS_USER_TYP_CDE,
MUS_USER_GRP,CALL_LTR,LIC_TYP_CDE,CALL_LTR_SUF,
STM_SUB_CAT_IND;
)] 'STM_CAT_GRP_AFMBR:LkpStmCatGrp.v'
;

#################################################################
#### STAGE: XfmChekNull2
## Operator
transform
## Operator options
-flag run
-name 'V0S43_CopyOfCreatePerfDtlsAFMBR_8162008_XfmChekNull2'

## General options
[ident('XfmChekNull2'); jobmon_ident('XfmChekNull2')]
## Inputs
0< 'Lkp_StmCAtGrp_PtyNA:LnkSCG_PtyNa.v'
## Outputs
0> [] 'XfmChekNull2:LnkAfmbrNA.v'
;

#################################################################
#### STAGE: DIS
## Operator
oraread
## Operator options
-dboptions '{user=[&DB_USER],password=[&DB_PWD]}'
-query 'SELECT DIS_ID, END_DT
FROM DIS
WHERE DEL_FL=\'N\'
and dis_typ_cde = \'DOMS\''
-server '[&DB_SERVER]'

## General options
[ident('DIS'); jobmon_ident('DIS')]
## Outputs
0> [modify (
DIS_ID:not_nullable decimal[15,0]=DIS_ID;
END_DT:nullable timestamp=END_DT;
keep
DIS_ID,END_DT;
)] 'DIS:LkpDis.v'
;

#################################################################
#### STAGE: PTY_NA
## Operator
oraread
## Operator options
-dboptions '{user=[&DB_USER],password=[&DB_PWD]}'
-query 'SELECT
PTY_NA_ID, PTY_ID, NVL(NA,\' \') LST_NA, NVL(FST_NA,\' \') FST_NA,
NVL(MID_INIT, \' \') MID_INIT, NVL(IPI_NA_NR, 0) IPI_NA_NR, NVL(SUF, \' \')
SUF
FROM PTY_NA
WHERE PTY_NA_TYP_CDE = \'PA\'
AND DEL_FL = \'N\''
-server '[&DB_SERVER]'

## General options
[ident('PTY_NA'); jobmon_ident('PTY_NA')]
## Outputs
0> [modify (
PTY_NA_ID:not_nullable decimal[15,0]=PTY_NA_ID;
PTY_ID:nullable int32=PTY_ID;
LST_NA:nullable string[max=90]=LST_NA;
FST_NA:nullable string[max=45]=FST_NA;
MID_INIT:nullable string[max=50]=MID_INIT;
IPI_NA_NR:nullable decimal[11,0]=IPI_NA_NR;
SUF:nullable string[max=20]=SUF;
keep
PTY_NA_ID,PTY_ID,LST_NA,FST_NA,
MID_INIT,IPI_NA_NR,SUF;
)] 'PTY_NA:LkpPtyNa.v'
;

#################################################################
#### STAGE: Lkp_DIS
## Operator
lookup
## Operator options
-table
-key ORG_DIS_ID
-ifNotFound continue

## General options
[ident('Lkp_DIS'); jobmon_ident('Lkp_DIS')]
## Inputs
0< 'XfmSeparateTransTyp:LnkTransTyp02.v'
1< [view (
ORG_DIS_ID=DIS_ID;
)] 'DIS:LkpDis.v'
## Outputs
0> [] 'Lkp_DIS:LnkDisInfo.v'
;

#################################################################
#### STAGE: XfmSetQtrYR
## Operator
transform
## Operator options
-flag run
-name 'V0S58_CopyOfCreatePerfDtlsAFMBR_8162008_XfmSetQtrYR'

## General options
[ident('XfmSetQtrYR'); jobmon_ident('XfmSetQtrYR')]
## Inputs
0< 'Lkp_DIS:LnkDisInfo.v'
## Outputs
0> [] 'XfmSetQtrYR:LnkTransTyp2Out.v'
;

#################################################################
#### STAGE: XfmSeparateTransTyp
## Operator
transform
## Operator options
-flag run
-name 'V0S62_CopyOfCreatePerfDtlsAFMBR_8162008_XfmSeparateTransTyp'

## General options
[ident('XfmSeparateTransTyp'); jobmon_ident('XfmSeparateTransTyp')]
## Inputs
0< 'XfmChekNull2:LnkAfmbrNA.v'
## Outputs
0> [] 'XfmSeparateTransTyp:LnkTransTyp02.v'
1> [] 'XfmSeparateTransTyp:LnkAll.v'
;

#################################################################
#### STAGE: FN_AllTransTypes
## Operator
funnel
## General options
[ident('FN_AllTransTypes'); jobmon_ident('FN_AllTransTypes')]
## Inputs
0< 'XfmSetQtrYR:LnkTransTyp2Out.v'
1< 'XfmSeparateTransTyp:LnkAll.v'
## Outputs
0> [modify (
CAL_LTR_SUF:nullable string[max=2]=CAL_LTR_SUF;
keep
ENT_EARN_LN_ID,ENT_EARN_PTY_ID,ENT_EARN_AMT,RYLT_LN_ID,
ORG_DIS_ID,ADJ_TRIG_ID,MUS_USR_PTY_ID,MUS_USR_TYP_CDE,
LIC_TYP_CDE,WRK_PERF_SHR_ID,SHR_OWN_PTY_NA_ID,PAYBL_OWN_PTY_NA_ID,
SHR_ADM_PTY_NA_ID,ENT_SHR,ROL_TYP_CDE,WRK_PERF_ID,
WRK_ID,WRK_TTL,PERF_HDR_ID,SER_TTL,
PGM_TTL,PGM_STT_DT,PGM_END_DT,PTY_NA_ID,
NA,STM_CAT_GRP_CDE,MUS_USER_GRP,SEC_IND,
TRAN_TYP,PYBL_PTY_NA,PYBL_PTY_IPI_NUM,STM_SUB_CAT_IND,
PREM_DOL,ORG_DIS_REF;
)] 'FN_AllTransTypes:LnkAllTransTypeOut.v'
;

#################################################################
#### STAGE: XfmTRansType
## Operator
transform
## Operator options
-flag run
-name 'V0S72_CopyOfCreatePerfDtlsAFMBR_8162008_XfmTRansType'

## General options
[ident('XfmTRansType'); jobmon_ident('XfmTRansType')]
## Inputs
0< 'FN_AllTransTypes:LnkAllTransTypeOut.v'
## Outputs
0> [] 'XfmTRansType:XfmTransTypesToJN.v'
;

#################################################################
#### STAGE: Aggr_Radio
## Operator
group
## Operator options
-hash
-key 'STMT_RECP_PTY_ID'
-key 'DOC_ID'
-key 'STM_NO'
-key 'WRK_TTL'
-key 'WRK_ID'
-key 'PYBL_PTY_NA'
-key 'PYBL_PTY_IPI_NUM'
-key 'ROL_TYP_CDE'
-key 'ENT_SHR'
-key 'SEC_IND'
-key 'TRAN_TYP'
-key 'ORG_DIS_REF'
-key 'MUS_USR_REF'
-key 'STM_CAT_GRP_CDE'
-key 'NA'
-key 'LIC_TYP_CDE'
-key 'CAL_LTR_SUF'
-key 'STM_SUB_CAT_IND'
-reduce 'ENT_EARN_AMT'
-sum 'TOT_DOL_AMT'
-decimal '16,5'
-reduce 'PREM_DOL'
-sum 'TOT_PREM_DOL'
-decimal '16,5'

## General options
[ident('Aggr_Radio'); jobmon_ident('Aggr_Radio'); seq]
## Inputs
0< 'Transformer_90:Radio.v'
## Outputs
0> [modify (
WRK_ID:nullable int32=WRK_ID;
ENT_SHR:nullable decimal[12,3]=ENT_SHR;
keep
STMT_RECP_PTY_ID,DOC_ID,STM_NO,WRK_TTL,
PYBL_PTY_NA,PYBL_PTY_IPI_NUM,ROL_TYP_CDE,SEC_IND,
TRAN_TYP,ORG_DIS_REF,MUS_USR_REF,STM_CAT_GRP_CDE,
NA,LIC_TYP_CDE,CAL_LTR_SUF,STM_SUB_CAT_IND,
TOT_DOL_AMT,TOT_PREM_DOL;
)] 'Aggr_Radio:LnkRadioAggred.v'
;

#################################################################
#### STAGE: Aggr_Audio
## Operator
group
## Operator options
-hash
-key 'STMT_RECP_PTY_ID'
-key 'DOC_ID'
-key 'STM_NO'
-key 'WRK_TTL'
-key 'WRK_ID'
-key 'PYBL_PTY_NA'
-key 'PYBL_PTY_IPI_NUM'
-key 'ROL_TYP_CDE'
-key 'ENT_SHR'
-key 'PGM_TTL'
-key 'SER_TTL'
-key 'SEC_IND'
-key 'TRAN_TYP'
-key 'ORG_DIS_REF'
-key 'MUS_USR_REF'
-key 'STM_CAT_GRP_CDE'
-key 'NA'
-key 'LIC_TYP_CDE'
-key 'CAL_LTR_SUF'
-key 'STM_SUB_CAT_IND'
-reduce 'ENT_EARN_AMT'
-sum 'TOT_DOL_AMT'
-decimal '16,5'
-reduce 'PREM_DOL'
-sum 'TOT_PREM_DOL'
-decimal '16,5'

## General options
[ident('Aggr_Audio'); jobmon_ident('Aggr_Audio'); seq]
## Inputs
0< 'Transformer_90:Audio.v'
## Outputs
0> [modify (
WRK_ID:nullable int32=WRK_ID;
ENT_SHR:nullable decimal[12,3]=ENT_SHR;
keep
STMT_RECP_PTY_ID,DOC_ID,STM_NO,WRK_TTL,
PYBL_PTY_NA,PYBL_PTY_IPI_NUM,ROL_TYP_CDE,PGM_TTL,
SER_TTL,SEC_IND,TRAN_TYP,ORG_DIS_REF,
MUS_USR_REF,STM_CAT_GRP_CDE,NA,LIC_TYP_CDE,
CAL_LTR_SUF,STM_SUB_CAT_IND,TOT_DOL_AMT,TOT_PREM_DOL;
)] 'Aggr_Audio:LnkAudioAggred.v'
;

#################################################################
#### STAGE: Jn_PtyDocInfo
## Operator
innerjoin
## Operator options
-key 'STMT_RECP_PTY_ID'

## General options
[ident('Jn_PtyDocInfo'); jobmon_ident('Jn_PtyDocInfo'); seq]
## Inputs
0< 'XfmTRansType:XfmTransTypesToJN.v'
1< 'PTY_DOC_INFO:LnkPtyDocInfo.v'
## Outputs
0> [modify (
keep
ENT_EARN_LN_ID,STMT_RECP_PTY_ID,ENT_EARN_AMT,RYLT_LN_ID,
ORG_DIS_ID,ADJ_TRIG_ID,MUS_USR_PTY_ID,MUS_USR_TYP_CDE,
LIC_TYP_CDE,WRK_PERF_SHR_ID,SHR_OWN_PTY_NA_ID,PAYBL_OWN_PTY_NA_ID,
SHR_ADM_PTY_NA_ID,ENT_SHR,ROL_TYP_CDE,WRK_PERF_ID,
WRK_ID,WRK_TTL,PERF_HDR_ID,SER_TTL,
PGM_TTL,PGM_STT_DT,PGM_END_DT,PTY_NA_ID,
NA,CAL_LTR_SUF,STM_CAT_GRP_CDE,MUS_USER_GRP,
SEC_IND,TRAN_TYP,PYBL_PTY_NA,PYBL_PTY_IPI_NUM,
STM_SUB_CAT_IND,ORG_DIS_REF,PREM_DOL,DOC_ID,
STM_NO,PAY_DIR_IND;
)] 'Jn_PtyDocInfo:LnkAfmbrWtPDI.v'
;

#################################################################
#### STAGE: PTY_DOC_INFO
## Operator
oraread
## Operator options
-dboptions '{user=[&PprepUserName],password=[&PprepPwd]}'
-query 'select DOC_ID,
PTY_ID STMT_RECP_PTY_ID,
DOC_TYP_CDE,
MW_STA,
RYLT_RUN_CTRL_ID,
PTY_TYP_CDE,
SP_PTY_ID,
STM_NO,
PMT_PLN_TYP_CDE,
PAY_DIR_IND
from pty_doc_info
where DOC_TYP_CDE=\'AFFL\'
and DEL_FL=\'N\'
--and PAY_DIR_IND =\'N\''
-server '[&DB_SERVER_QA]'

## General options
[ident('PTY_DOC_INFO'); jobmon_ident('PTY_DOC_INFO')]
## Outputs
0> [modify (
DOC_ID:nullable int32=DOC_ID;
STMT_RECP_PTY_ID:nullable int32=STMT_RECP_PTY_ID;
DOC_TYP_CDE:nullable string[max=5]=DOC_TYP_CDE;
MW_STA:nullable string[max=20]=MW_STA;
RYLT_RUN_CTRL_ID:nullable int32=RYLT_RUN_CTRL_ID;
PTY_TYP_CDE:nullable string[max=5]=PTY_TYP_CDE;
SP_PTY_ID:nullable int32=SP_PTY_ID;
STM_NO:nullable int32=STM_NO;
PMT_PLN_TYP_CDE:nullable string[max=3]=PMT_PLN_TYP_CDE;
PAY_DIR_IND:nullable string[1]=PAY_DIR_IND;
keep
DOC_ID,STMT_RECP_PTY_ID,DOC_TYP_CDE,MW_STA,
RYLT_RUN_CTRL_ID,PTY_TYP_CDE,SP_PTY_ID,STM_NO,
PMT_PLN_TYP_CDE,PAY_DIR_IND;
)] 'PTY_DOC_INFO:LnkPtyDocInfo.v'
;

#################################################################
#### STAGE: Transformer_90
## Operator
transform
## Operator options
-flag run
-name 'V0S90_CopyOfCreatePerfDtlsAFMBR_8162008_Transformer_90'

## General options
[ident('Transformer_90'); jobmon_ident('Transformer_90')]
## Inputs
0< 'Jn_PtyDocInfo:LnkAfmbrWtPDI.v'
## Outputs
0> [] 'Transformer_90:Audio.v'
1> [] 'Transformer_90:Radio.v'
2> [] 'Transformer_90:PayDir.v'
;

#################################################################
#### STAGE: XfmSetPgmTtlAudio
## Operator
transform
## Operator options
-flag run
-name 'V0S95_CopyOfCreatePerfDtlsAFMBR_8162008_XfmSetPgmTtlAudio'

## General options
[ident('XfmSetPgmTtlAudio'); jobmon_ident('XfmSetPgmTtlAudio')]
## Inputs
0< 'Aggr_Audio:LnkAudioAggred.v'
## Outputs
0> [] 'XfmSetPgmTtlAudio:LnkAudioInfo.v'
;

#################################################################
#### STAGE: XfmSetPgmTtlRadio
## Operator
transform
## Operator options
-flag run
-name 'V0S96_CopyOfCreatePerfDtlsAFMBR_8162008_XfmSetPgmTtlRadio'

## General options
[ident('XfmSetPgmTtlRadio'); jobmon_ident('XfmSetPgmTtlRadio')]
## Inputs
0< 'Aggr_Radio:LnkRadioAggred.v'
## Outputs
0> [] 'XfmSetPgmTtlRadio:LnkRadioInfo.v'
;

#################################################################
#### STAGE: Fn_RadioAudio
## Operator
funnel
## General options
[ident('Fn_RadioAudio'); jobmon_ident('Fn_RadioAudio')]
## Inputs
0< 'XfmSetPgmTtlAudio:LnkAudioInfo.v'
1< 'XfmSetPgmTtlRadio:LnkRadioInfo.v'
2< 'XfmPayDirDtlAggr:LnkPayDirInfo.v'
## Outputs
0> [modify (
keep
STMT_RECP_PTY_ID,DOC_ID,STM_NO,SEC_IND,
TRAN_TYP,WRK_TTL,WRK_ID,PYBL_PTY_NA,
PYBL_PTY_IPI_NUM,ROL_TYP_CDE,ENT_SHR,PGM_TTL,
SER_TTL,MUS_USR_REF,ORG_DIS_REF,STM_CAT_GRP_CDE,
NA,LIC_TYP_CDE,CAL_LTR_SUF,STM_SUB_CAT_IND,
TOT_DOL_AMT,TOT_PREM_DOL;
)] 'Fn_RadioAudio:LnkRadAud.v'
;

#################################################################
#### STAGE: PERF_DTLS
## Operator
export
## Operator options
-schema record
{final_delim=end, delim=none, null_field=' ', quote=none}
(
SORT_KEY:nullable string[151];
REC_TYPE:nullable string[4];
STMT_RECP_PTY_ID:nullable string[9];
DOC_ID:nullable string[10];
STM_NO:nullable string[10];
LINE_NUM:nullable string[10];
SEC_IND:nullable string[2];
TRAN_TYP:nullable string[2];
ORG_TTL:nullable string[50];
WRK_ID:nullable string[11];
PYBL_PTY_NA:nullable string[185];
PYBL_PTY_IPI_NUM:nullable string[11];
ROL_TYP_CDE:nullable string[2];
ENT_SHR:nullable string[12];
PGM_TTL:nullable string[50];
SER_TTL:nullable string[50];
MUS_USR_REF:nullable string[50];
PGM_DT:string[50];
ORG_DIS_REF:nullable string[6];
TOT_DOL_AMT:nullable string[22];
TOT_PREM_DOL:nullable string[22];
)
-file '[&CUFF_WRK_DIR]/MWS_AFFL_[&StmtRunCtlID]_PDTL.txt'
-overwrite
-rejects continue

## General options
[ident('PERF_DTLS'); jobmon_ident('PERF_DTLS')]
## Inputs
0< 'XfmPrefDtls:PerfDtls.v'
;

#################################################################
#### STAGE: XfmFormatPgmSttEntDt
## Operator
transform
## Operator options
-flag run
-name 'V0S118_CopyOfCreatePerfDtlsAFMBR_8162008_XfmFormatPgmSttEntDt'

## General options
[ident('XfmFormatPgmSttEntDt'); jobmon_ident('XfmFormatPgmSttEntDt')]
## Inputs
0< 'Fn_RadioAudio:LnkRadAud.v'
## Outputs
0> [] 'XfmFormatPgmSttEntDt:LnkRadAudInfo.v'
;

#################################################################
#### STAGE: XfmPrefDtls
## Operator
transform
## Operator options
-flag run
-name 'V0S122_CopyOfCreatePerfDtlsAFMBR_8162008_XfmPrefDtls'

## General options
[ident('XfmPrefDtls'); jobmon_ident('XfmPrefDtls')]
## Inputs
0< 'XfmFormatPgmSttEntDt:LnkRadAudInfo.v'
## Outputs
0> [] 'XfmPrefDtls:PerfDtls.v'
1> [] 'XfmPrefDtls:Curr.v'
2> [] 'XfmPrefDtls:Total.v'
3> [] 'XfmPrefDtls:Adj.v'
4> [] 'XfmPrefDtls:PerfDtlsHdrFtr.v'
;

#################################################################
#### STAGE: Aggr_CurrAmt
## Operator
group
## Operator options
-hash
-key 'STMT_RECP_PTY_ID'
-key 'DOC_ID'
-key 'STM_NO'
-key 'LINE_NUM'
-key 'SEC_IND'
-key 'TRAN_TYP'
-key 'STM_CAT_GRP_CDE'
-key 'STM_SUB_CAT_IND'
-key 'NA'
-key 'LIC_TYP_CDE'
-key 'CAL_LTR_SUF'
-reduce 'TOT_DOL_AMT'
-sum 'TOT_DOL_AMT'
-decimal '16,5'

## General options
[ident('Aggr_CurrAmt'); jobmon_ident('Aggr_CurrAmt'); seq]
## Inputs
0< 'XfmPrefDtls:Curr.v'
## Outputs
0> [modify (
keep
STMT_RECP_PTY_ID,DOC_ID,STM_NO,LINE_NUM,
SEC_IND,TRAN_TYP,STM_CAT_GRP_CDE,STM_SUB_CAT_IND,
NA,TOT_DOL_AMT;
)] 'Aggr_CurrAmt:LnkTotCurr.v'
;

#################################################################
#### STAGE: Aggr_TotDolAmt
## Operator
group
## Operator options
-hash
-key 'STMT_RECP_PTY_ID'
-key 'DOC_ID'
-key 'STM_NO'
-key 'LINE_NUM'
-key 'SEC_IND'
-key 'STM_CAT_GRP_CDE'
-key 'STM_SUB_CAT_IND'
-key 'NA'
-key 'LIC_TYP_CDE'
-key 'CAL_LTR_SUF'
-reduce 'TOT_DOL_AMT'
-sum 'TOT_DOL_AMT'
-decimal '16,5'

## General options
[ident('Aggr_TotDolAmt'); jobmon_ident('Aggr_TotDolAmt'); seq]
## Inputs
0< 'XfmPrefDtls:Total.v'
## Outputs
0> [modify (
keep
STMT_RECP_PTY_ID,DOC_ID,STM_NO,LINE_NUM,
SEC_IND,STM_CAT_GRP_CDE,STM_SUB_CAT_IND,NA,
TOT_DOL_AMT;
)] 'Aggr_TotDolAmt:LnkTotDolAggred.v'
;

#################################################################
#### STAGE: XfmSetTransTyp00
## Operator
transform
## Operator options
-flag run
-name 'V0S134_CopyOfCreatePerfDtlsAFMBR_8162008_XfmSetTransTyp00'

## General options
[ident('XfmSetTransTyp00'); jobmon_ident('XfmSetTransTyp00')]
## Inputs
0< 'Aggr_TotDolAmt:LnkTotDolAggred.v'
## Outputs
0> [] 'XfmSetTransTyp00:LnkTotDol.v'
;

#################################################################
#### STAGE: Fn_AllAmts
## Operator
funnel
## General options
[ident('Fn_AllAmts'); jobmon_ident('Fn_AllAmts')]
## Inputs
0< 'Aggr_CurrAmt:LnkTotCurr.v'
1< 'XfmSetTransTyp00:LnkTotDol.v'
2< 'Aggr_AdjAmt:LnkTotAdj.v'
## Outputs
0> [modify (
keep
STMT_RECP_PTY_ID,DOC_ID,STM_NO,LINE_NUM,
SEC_IND,TRAN_TYP,STM_CAT_GRP_CDE,STM_SUB_CAT_IND,
NA,TOT_DOL_AMT;
)] 'Fn_AllAmts:LnkAllAmts.v'
;

#################################################################
#### STAGE: Xfm1
## Operator
transform
## Operator options
-flag run
-name 'V0S142_CopyOfCreatePerfDtlsAFMBR_8162008_Xfm1'

## General options
[ident('Xfm1'); jobmon_ident('Xfm1')]
## Inputs
0< 'Fn_AllAmts:LnkAllAmts.v'
## Outputs
0> [] 'Xfm1:LnkAggrWtSEcInd.v'
1> [] 'Xfm1:LnkAggrWOSecInd.v'
2> [] 'Xfm1:LnkAllSecs1.v'
;

#################################################################
#### STAGE: Aggr_WtSecInd
## Operator
group
## Operator options
-hash
-key 'STMT_RECP_PTY_ID'
-key 'DOC_ID'
-key 'STM_NO'
-key 'LINE_NUM'
-key 'SEC_IND'
-key 'TRAN_TYP'
-reduce 'TOT_DOL_AMT'
-sum 'TOT_DOL_AMT'
-decimal '16,5'

## General options
[ident('Aggr_WtSecInd'); jobmon_ident('Aggr_WtSecInd'); seq]
## Inputs
0< 'Xfm1:LnkAggrWtSEcInd.v'
## Outputs
0> [modify (
keep
STMT_RECP_PTY_ID,DOC_ID,STM_NO,LINE_NUM,
SEC_IND,TRAN_TYP,TOT_DOL_AMT;
)] 'Aggr_WtSecInd:LnkAggr1.v'
;

#################################################################
#### STAGE: Aggr_WOSecInd
## Operator
group
## Operator options
-hash
-key 'STMT_RECP_PTY_ID'
-key 'DOC_ID'
-key 'STM_NO'
-key 'LINE_NUM'
-key 'TRAN_TYP'
-reduce 'TOT_DOL_AMT'
-sum 'TOT_DOL_AMT'
-decimal '16,5'

## General options
[ident('Aggr_WOSecInd'); jobmon_ident('Aggr_WOSecInd'); seq]
## Inputs
0< 'Xfm1:LnkAggrWOSecInd.v'
## Outputs
0> [modify (
keep
STMT_RECP_PTY_ID,DOC_ID,STM_NO,LINE_NUM,
TRAN_TYP,TOT_DOL_AMT;
)] 'Aggr_WOSecInd:LnkAggr2.v'
;

#################################################################
#### STAGE: XfmSetStmCat00
## Operator
transform
## Operator options
-flag run
-name 'V0S152_CopyOfCreatePerfDtlsAFMBR_8162008_XfmSetStmCat00'

## General options
[ident('XfmSetStmCat00'); jobmon_ident('XfmSetStmCat00')]
## Inputs
0< 'Aggr_WtSecInd:LnkAggr1.v'
## Outputs
0> [] 'XfmSetStmCat00:LnkStmCat00.v'
;

#################################################################
#### STAGE: XfmSetStmCatSecInd00
## Operator
transform
## Operator options
-flag run
-name 'V0S155_CopyOfCreatePerfDtlsAFMBR_8162008_XfmSetStmCatSecInd00'

## General options
[ident('XfmSetStmCatSecInd00'); jobmon_ident('XfmSetStmCatSecInd00')]
## Inputs
0< 'Aggr_WOSecInd:LnkAggr2.v'
## Outputs
0> [] 'XfmSetStmCatSecInd00:LnkStmCatSecInd00.v'
;

#################################################################
#### STAGE: Fn_AllSecInds
## Operator
funnel
## General options
[ident('Fn_AllSecInds'); jobmon_ident('Fn_AllSecInds')]
## Inputs
0< 'XfmSetStmCat00:LnkStmCat00.v'
1< 'XfmSetStmCatSecInd00:LnkStmCatSecInd00.v'
## Outputs
0> [modify (
keep
STMT_RECP_PTY_ID,DOC_ID,STM_NO,LINE_NUM,
SEC_IND,STM_CAT,TRAN_TYP,TOT_DOL_AMT;
)] 'Fn_AllSecInds:LnkAllSecInds.v'
;

#################################################################
#### STAGE: PERF_SUM
## Operator
export
## Operator options
-schema record
{final_delim=end, delim=none, null_field=' ', quote=none}
(
SORT_KEY:nullable string[151];
RECORD_TYP:nullable string[4];
STMT_RECP_PTY_ID:nullable string[9];
DOC_ID:nullable string[10];
STM_NO:nullable string[10];
LINE_NUM:nullable string[10];
SEC_IND:nullable string[2];
TRAN_TYP:nullable string[2];
STM_CAT:nullable string[2];
STM_SUB_CAT_IND:nullable string[1];
STM_SUB_CAT_LBL:nullable string[50];
TOT_DOL_AMT:nullable string[16];
)
-file '[&CUFF_WRK_DIR]/MWS_AFFL_[&StmtRunCtlID]_PSUM.txt'
-overwrite
-rejects continue

## General options
[ident('PERF_SUM'); jobmon_ident('PERF_SUM')]
## Inputs
0< 'XfmPerfSum:PerfSumOUT.v'
;

#################################################################
#### STAGE: Xfm2
## Operator
transform
## Operator options
-flag run
-name 'V0S165_CopyOfCreatePerfDtlsAFMBR_8162008_Xfm2'

## General options
[ident('Xfm2'); jobmon_ident('Xfm2')]
## Inputs
0< 'Fn_AllSecInds:LnkAllSecInds.v'
## Outputs
0> [] 'Xfm2:LnkAllSEcs2.v'
;

#################################################################
#### STAGE: Fn_AllSecs
## Operator
funnel
## General options
[ident('Fn_AllSecs'); jobmon_ident('Fn_AllSecs')]
## Inputs
0< 'Xfm1:LnkAllSecs1.v'
1< 'Xfm2:LnkAllSEcs2.v'
## Outputs
0> [modify (
keep
STMT_RECP_PTY_ID,DOC_ID,STM_NO,LINE_NUM,
SEC_IND,TRAN_TYP,STM_CAT_GRP_CDE,STM_SUB_CAT_IND,
NA,TOT_DOL_AMT;
)] 'Fn_AllSecs:LnkAllSecs.v'
;

#################################################################
#### STAGE: Aggr_AdjAmt
## Operator
group
## Operator options
-hash
-key 'STMT_RECP_PTY_ID'
-key 'DOC_ID'
-key 'STM_NO'
-key 'LINE_NUM'
-key 'SEC_IND'
-key 'TRAN_TYP'
-key 'STM_CAT_GRP_CDE'
-key 'STM_SUB_CAT_IND'
-key 'NA'
-key 'LIC_TYP_CDE'
-key 'CAL_LTR_SUF'
-reduce 'TOT_DOL_AMT'
-sum 'TOT_DOL_AMT'
-decimal '16,5'

## General options
[ident('Aggr_AdjAmt'); jobmon_ident('Aggr_AdjAmt'); seq]
## Inputs
0< 'XfmPrefDtls:Adj.v'
## Outputs
0> [modify (
keep
STMT_RECP_PTY_ID,DOC_ID,STM_NO,LINE_NUM,
SEC_IND,TRAN_TYP,STM_CAT_GRP_CDE,STM_SUB_CAT_IND,
NA,TOT_DOL_AMT;
)] 'Aggr_AdjAmt:LnkTotAdj.v'
;

#################################################################
#### STAGE: Aggr_PerfDtlsHdrFtr
## Operator
group
## Operator options
-hash
-key 'STMT_RECP_PTY_ID'
-key 'DOC_ID'
-key 'STM_NO'
-key 'LINE_NUM'
-key 'SEC_IND'
-countField 'TOT_CNT_DTL_RECS'

## General options
[ident('Aggr_PerfDtlsHdrFtr'); jobmon_ident('Aggr_PerfDtlsHdrFtr'); seq]
## Inputs
0< 'XfmPrefDtls:PerfDtlsHdrFtr.v'
## Outputs
0> [modify (
TOT_CNT_DTL_RECS:nullable int32=TOT_CNT_DTL_RECS;
keep
STMT_RECP_PTY_ID,DOC_ID,STM_NO,LINE_NUM,
SEC_IND;
)] 'Aggr_PerfDtlsHdrFtr:LnkPrefDtlsHdrFtrAggr.v'
;

#################################################################
#### STAGE: XfmPerfHdrHdrFtr
## Operator
transform
## Operator options
-flag run
-name 'V0S218_CopyOfCreatePerfDtlsAFMBR_8162008_XfmPerfHdrHdrFtr'

## General options
[ident('XfmPerfHdrHdrFtr'); jobmon_ident('XfmPerfHdrHdrFtr')]
## Inputs
0< 'Aggr_PerfDtlsHdrFtr:LnkPrefDtlsHdrFtrAggr.v'
## Outputs
0> [] 'XfmPerfHdrHdrFtr:PerfHdrOUT.v'
1> [] 'XfmPerfHdrHdrFtr:PerfFtrOut.v'
;

#################################################################
#### STAGE: PERF_DTL_HDR
## Operator
export
## Operator options
-schema record
{final_delim=end, delim=none, null_field=' ', quote=none}
(
SORT_KEY:nullable string[151];
RECORD_TYP:string[4];
STMT_RECP_PTY_ID:nullable string[9];
DOC_ID:nullable string[10];
STM_NO:nullable string[10];
LINE_NUM:nullable string[10];
SEC_IND:nullable string[2];
)
-file '[&CUFF_WRK_DIR]/MWS_AFFL_[&StmtRunCtlID]_PDTLHDR.txt'
-overwrite
-rejects continue

## General options
[ident('PERF_DTL_HDR'); jobmon_ident('PERF_DTL_HDR')]
## Inputs
0< 'XfmPerfHdrHdrFtr:PerfHdrOUT.v'
;

#################################################################
#### STAGE: PERF_DTL_FTR
## Operator
export
## Operator options
-schema record
{final_delim=end, delim=none, null_field=' ', quote=none}
(
SORT_KEY:nullable string[151];
RECORD_TYP:string[4];
STMT_RECP_PTY_ID:nullable string[9];
DOC_ID:nullable string[10];
STM_NO:nullable string[10];
LINE_NUM:nullable string[10];
SEC_IND:nullable string[2];
TOT_CNT_DTL_RECS:nullable string[10];
)
-file '[&CUFF_WRK_DIR]/MWS_AFFL_[&StmtRunCtlID]_PDTLFTR.txt'
-overwrite
-rejects continue

## General options
[ident('PERF_DTL_FTR'); jobmon_ident('PERF_DTL_FTR')]
## Inputs
0< 'XfmPerfHdrHdrFtr:PerfFtrOut.v'
;

#################################################################
#### STAGE: XfmPerfSum
## Operator
transform
## Operator options
-flag run
-name 'V0S225_CopyOfCreatePerfDtlsAFMBR_8162008_XfmPerfSum'

## General options
[ident('XfmPerfSum'); jobmon_ident('XfmPerfSum')]
## Inputs
0< 'Fn_AllSecs:LnkAllSecs.v'
## Outputs
0> [] 'XfmPerfSum:PerfSumOUT.v'
1> [] 'XfmPerfSum:PerfSumHdrFtr.v'
2> [] 'XfmPerfSum:DSLink369.v'
;

#################################################################
#### STAGE: Aggr_TotRecs
## Operator
group
## Operator options
-hash
-key 'STMT_RECP_PTY_ID'
-key 'DOC_ID'
-key 'STM_NO'
-key 'LINE_NUM'
-key 'SEC_IND'
-countField 'TOT_CNT_SUM_RECS'

## General options
[ident('Aggr_TotRecs'); jobmon_ident('Aggr_TotRecs'); seq]
## Inputs
0< 'XfmPerfSum:PerfSumHdrFtr.v'
## Outputs
0> [modify (
keep
STMT_RECP_PTY_ID,DOC_ID,STM_NO,LINE_NUM,
SEC_IND,TOT_CNT_SUM_RECS;
)] 'Aggr_TotRecs:LnkTotRecsAggred.v'
;

#################################################################
#### STAGE: XfmRestFiles
## Operator
transform
## Operator options
-flag run
-name 'V0S233_CopyOfCreatePerfDtlsAFMBR_8162008_XfmRestFiles'

## General options
[ident('XfmRestFiles'); jobmon_ident('XfmRestFiles')]
## Inputs
0< 'Aggr_TotRecs:LnkTotRecsAggred.v'
## Outputs
0> [] 'XfmRestFiles:PerfSumHdrOUT.v'
1> [] 'XfmRestFiles:PerfSumFtrOUT.v'
2> [] 'XfmRestFiles:StmFtr.v'
3> [] 'XfmRestFiles:SecHdrOUT.v'
4> [] 'XfmRestFiles:SecFtrOUT.v'
;

#################################################################
#### STAGE: PERF_SUM_HDR
## Operator
export
## Operator options
-schema record
{final_delim=end, delim=none, null_field=' ', quote=none}
(
SORT_KEY:nullable string[151];
RECORD_TYP:nullable string[4];
STMT_RECP_PTY_ID:nullable string[9];
DOC_ID:nullable string[10];
STM_NO:nullable string[10];
LINE_NUM:nullable string[10];
SEC_IND:nullable string[2];
)
-file '[&CUFF_WRK_DIR]/MWS_AFFL_[&StmtRunCtlID]_PSUMHDR.txt'
-overwrite
-rejects continue

## General options
[ident('PERF_SUM_HDR'); jobmon_ident('PERF_SUM_HDR')]
## Inputs
0< 'XfmRestFiles:PerfSumHdrOUT.v'
;

#################################################################
#### STAGE: PERF_SUM_FTR
## Operator
export
## Operator options
-schema record
{final_delim=end, delim=none, null_field=' ', quote=none}
(
SORT_KEY:nullable string[151];
RECORD_TYP:nullable string[4];
STMT_RECP_PTY_ID:nullable string[9];
DOC_ID:nullable string[10];
STM_NO:nullable string[10];
LINE_NUM:nullable string[10];
SEC_IND:nullable string[2];
)
-file '[&CUFF_WRK_DIR]/MWS_AFFL_[&StmtRunCtlID]_PSUMFTR.txt'
-overwrite
-rejects continue

## General options
[ident('PERF_SUM_FTR'); jobmon_ident('PERF_SUM_FTR')]
## Inputs
0< 'XfmRestFiles:PerfSumFtrOUT.v'
;

#################################################################
#### STAGE: JN_SocForPayDir
## Operator
innerjoin
## Operator options
-key 'PAY_DIR_PTY_ID'

## General options
[ident('JN_SocForPayDir'); jobmon_ident('JN_SocForPayDir'); seq]
## Inputs
0< 'XfmSocCde:LnkSocForPayDir.v'
1< 'XfmPayDir:LnkPayDirIN.v'
## Outputs
0> [modify (
keep
PAY_DIR_PTY_ID,USA_SOC_CDE,PTY_ID,WRK_TTL,
WRK_ID,ROL_TYP_CDE,ENT_SHR,SEC_IND,
TRAN_TYP,ORG_DIS_REF,MUS_USR_REF,STM_CAT_GRP_CDE,
NA,LIC_TYP_CDE,CAL_LTR_SUF,STM_SUB_CAT_IND,
TOT_DOL_AMT,TOT_PREM_DOL;
)] 'JN_SocForPayDir:LnkPayDirWtSoc.v'
;

#################################################################
#### STAGE: GetSocCode_FromPTY
## Operator
oraread
## Operator options
-dboptions '{user=[&PprepUserName],password=[&PprepPwd]}'
-query 'select pdi.pty_id PAY_DIR_PTY_ID,recp.usa_soc_cde,soc.pty_id pty_id
from pty_doc_info pdi, pty recp, pty soc
where
pdi.pty_typ_cde = \'AFMBR\' and
pdi.pay_dir_ind = \'Y\' and
pdi.pty_id=recp.pty_id and
recp.usa_soc_cde=soc.soc_cde
--order by 2'
-server '[&DB_SERVER_QA]'

## General options
[ident('GetSocCode_FromPTY'); jobmon_ident('GetSocCode_FromPTY')]
## Outputs
0> [modify (
PAY_DIR_PTY_ID:nullable int32=PAY_DIR_PTY_ID;
USA_SOC_CDE:nullable string[max=25]=USA_SOC_CDE;
PTY_ID:nullable int32=PTY_ID;
keep
PAY_DIR_PTY_ID,USA_SOC_CDE,PTY_ID;
)] 'GetSocCode_FromPTY:LnkSocCde.v'
;

#################################################################
#### STAGE: XfmSocWtPayDir
## Operator
transform
## Operator options
-flag run
-name 'V0S250_CopyOfCreatePerfDtlsAFMBR_8162008_XfmSocWtPayDir'

## General options
[ident('XfmSocWtPayDir'); jobmon_ident('XfmSocWtPayDir')]
## Inputs
0< 'JN_SocForPayDir:LnkPayDirWtSoc.v'
## Outputs
0> [] 'XfmSocWtPayDir:LnkPayDir.v'
;

#################################################################
#### STAGE: Jn_PayDirPtyNa
## Operator
innerjoin
## Operator options
-key 'PAY_DIR_PTY_ID'

## General options
[ident('Jn_PayDirPtyNa'); jobmon_ident('Jn_PayDirPtyNa'); seq]
## Inputs
0< 'XfmSocWtPayDir:LnkPayDir.v'
1< 'PTY_NA_For_PayDir:LnkPtyNaIN.v'
## Outputs
0> [modify (
keep
PAY_DIR_PTY_ID,PTY_ID,USA_SOC_CDE,WRK_TTL,
WRK_ID,ROL_TYP_CDE,ENT_SHR,SEC_IND,
TRAN_TYP,ORG_DIS_REF,MUS_USR_REF,STM_CAT_GRP_CDE,
MUS_USER_NA,LIC_TYP_CDE,CAL_LTR_SUF,STM_SUB_CAT_IND,
TOT_DOL_AMT,TOT_PREM_DOL,NA,FST_NA,
MID_INIT,IPI_NA_NR,SUF;
)] 'Jn_PayDirPtyNa:LnkPayDirNA.v'
;

#################################################################
#### STAGE: PTY_NA_For_PayDir
## Operator
oraread
## Operator options
-dboptions '{user=[&DB_USER],password=[&DB_PWD]}'
-query 'select pty_id PAY_DIR_PTY_ID,na,fst_na,nvl(mid_init, \' \') mid_init, nvl(ipi_na_nr,0) ipi_na_nr, nvl(suf, \' \') suf
from pty_na
where pty_na_typ_cde=\'PA\' and
del_fl=\'N\''
-server '[&DB_SERVER]'

## General options
[ident('PTY_NA_For_PayDir'); jobmon_ident('PTY_NA_For_PayDir')]
## Outputs
0> [modify (
PAY_DIR_PTY_ID:nullable int32=PAY_DIR_PTY_ID;
NA:nullable string[max=90]=NA;
FST_NA:nullable string[max=45]=FST_NA;
MID_INIT:nullable string[max=50]=MID_INIT;
IPI_NA_NR:nullable int32=IPI_NA_NR;
SUF:nullable string[max=20]=SUF;
keep
PAY_DIR_PTY_ID,NA,FST_NA,MID_INIT,
IPI_NA_NR,SUF;
)] 'PTY_NA_For_PayDir:LnkPtyNaIN.v'
;

#################################################################
#### STAGE: XfmPayDirNA
## Operator
transform
## Operator options
-flag run
-name 'V0S258_CopyOfCreatePerfDtlsAFMBR_8162008_XfmPayDirNA'

## General options
[ident('XfmPayDirNA'); jobmon_ident('XfmPayDirNA')]
## Inputs
0< 'Jn_PayDirPtyNa:LnkPayDirNA.v'
## Outputs
0> [] 'XfmPayDirNA:LnkNA.v'
;

#################################################################
#### STAGE: Jn_PDI_PayDirNA
## Operator
innerjoin
## Operator options
-key 'STMT_RECP_PTY_ID'

## General options
[ident('Jn_PDI_PayDirNA'); jobmon_ident('Jn_PDI_PayDirNA'); seq]
## Inputs
0< 'XfmPayDirNA:LnkNA.v'
1< 'PTY_DOC_INFO_ForPayDir:LnkPDI.v'
## Outputs
0> [modify (
keep
STMT_RECP_PTY_ID,PAY_DIR_PTY_ID,NA,FST_NA,
MID_INIT,IPI_NA_NR,SUF,DOC_ID,
STM_NO,USA_SOC_CDE,WRK_TTL,WRK_ID,
ROL_TYP_CDE,ENT_SHR,SEC_IND,TRAN_TYP,
ORG_DIS_REF,MUS_USR_REF,STM_CAT_GRP_CDE,MUS_USER_NA,
LIC_TYP_CDE,CAL_LTR_SUF,STM_SUB_CAT_IND,TOT_DOL_AMT,
TOT_PREM_DOL,DOC_TYP_CDE,MW_STA,RYLT_RUN_CTRL_ID,
PTY_TYP_CDE,SP_PTY_ID,PMT_PLN_TYP_CDE,PAY_DIR_IND;
)] 'Jn_PDI_PayDirNA:LnkPayDirNA.v'
;

#################################################################
#### STAGE: PTY_DOC_INFO_ForPayDir
## Operator
oraread
## Operator options
-dboptions '{user=[&PprepUserName],password=[&PprepPwd]}'
-query 'select DOC_ID,
PTY_ID STMT_RECP_PTY_ID,
DOC_TYP_CDE,
MW_STA,
RYLT_RUN_CTRL_ID,
PTY_TYP_CDE,
SP_PTY_ID,
STM_NO,
PMT_PLN_TYP_CDE,
PAY_DIR_IND
from pty_doc_info
where DOC_TYP_CDE=\'AFFL\'
--and PTY_TYP_CDE in (\'AFMBR\', \'SUCCR\')
and DEL_FL=\'N\''
-server '[&DB_SERVER_QA]'

## General options
[ident('PTY_DOC_INFO_ForPayDir'); jobmon_ident('PTY_DOC_INFO_ForPayDir')]
## Outputs
0> [modify (
DOC_ID:nullable int32=DOC_ID;
STMT_RECP_PTY_ID:nullable int32=STMT_RECP_PTY_ID;
DOC_TYP_CDE:nullable string[max=5]=DOC_TYP_CDE;
MW_STA:nullable string[max=20]=MW_STA;
RYLT_RUN_CTRL_ID:nullable int32=RYLT_RUN_CTRL_ID;
PTY_TYP_CDE:nullable string[max=5]=PTY_TYP_CDE;
SP_PTY_ID:nullable int32=SP_PTY_ID;
STM_NO:nullable int32=STM_NO;
PMT_PLN_TYP_CDE:nullable string[max=3]=PMT_PLN_TYP_CDE;
PAY_DIR_IND:nullable string[1]=PAY_DIR_IND;
keep
DOC_ID,STMT_RECP_PTY_ID,DOC_TYP_CDE,MW_STA,
RYLT_RUN_CTRL_ID,PTY_TYP_CDE,SP_PTY_ID,STM_NO,
PMT_PLN_TYP_CDE,PAY_DIR_IND;
)] 'PTY_DOC_INFO_ForPayDir:LnkPDI.v'
;

#################################################################
#### STAGE: XfmPayDirDtlAggr
## Operator
transform
## Operator options
-flag run
-name 'V0S265_CopyOfCreatePerfDtlsAFMBR_8162008_XfmPayDirDtlAggr'

## General options
[ident('XfmPayDirDtlAggr'); jobmon_ident('XfmPayDirDtlAggr')]
## Inputs
0< 'Jn_PDI_PayDirNA:LnkPayDirNA.v'
## Outputs
0> [] 'XfmPayDirDtlAggr:LnkPayDirInfo.v'
1> [] 'XfmPayDirDtlAggr:LnkPayDirDtl.v'
;

#################################################################
#### STAGE: PAY_DIR_DTL
## Operator
export
## Operator options
-schema record
{final_delim=end, delim=none, null_field=' ', quote=none}
(
SORT_KEY:nullable string[151];
RECORD_TYP:nullable string[4];
PTY_ID:nullable string[9];
DOC_ID:nullable string[10];
STM_NO:nullable string[10];
LINE_NUM:nullable string[10];
PAY_DIR_PTY_NA:nullable string[185];
IPI_NA_NR:nullable string[15];
TOT_ENT_EARN_AMT:nullable string[16];
)
-file '[&CUFF_WRK_DIR]/MWS_AFFL_[&StmtRunCtlID]_PAYDIRDTL.txt'
-overwrite
-rejects continue

## General options
[ident('PAY_DIR_DTL'); jobmon_ident('PAY_DIR_DTL')]
## Inputs
0< 'Transformer_363:PayDirOUT.v'
;

#################################################################
#### STAGE: XfmSocCde
## Operator
transform
## Operator options
-flag run
-name 'V0S281_CopyOfCreatePerfDtlsAFMBR_8162008_XfmSocCde'

## General options
[ident('XfmSocCde'); jobmon_ident('XfmSocCde')]
## Inputs
0< 'GetSocCode_FromPTY:LnkSocCde.v'
## Outputs
0> [] 'XfmSocCde:LnkSocForPayDir.v'
;

#################################################################
#### STAGE: XfmPayDir
## Operator
transform
## Operator options
-flag run
-name 'V0S284_CopyOfCreatePerfDtlsAFMBR_8162008_XfmPayDir'

## General options
[ident('XfmPayDir'); jobmon_ident('XfmPayDir')]
## Inputs
0< 'Aggr_PayDir:LnkPayDirAggred.v'
## Outputs
0> [] 'XfmPayDir:LnkPayDirIN.v'
;

#### STAGE: Aggr_ForPayDirHdrFtr.LnkPayDirHdrFtr_Part
## Operator
hash -key PTY_ID
## General options
[ident('Aggr_ForPayDirHdrFtr.LnkPayDirHdrFtr_Part')]
## Inputs
0< 'Transformer_363:LnkPayDirHdrFtr.v'
## Outputs
0> [] 'Transformer_363:LnkPayDirHdrFtr_Part.v'
;

#### STAGE: Aggr_ForPayDirHdrFtr.LnkPayDirHdrFtr_Sort
## Operator
tsort -key PTY_ID -asc -nulls first -nonStable
## General options
[ident('Aggr_ForPayDirHdrFtr.LnkPayDirHdrFtr_Sort')]
## Inputs
0< 'Transformer_363:LnkPayDirHdrFtr_Part.v'
## Outputs
0> [] 'Transformer_363:LnkPayDirHdrFtr_Part_Sort.v'
;

#################################################################
#### STAGE: Aggr_ForPayDirHdrFtr
## Operator
group
## Operator options
-sort
-key 'PTY_ID'
-key 'DOC_ID'
-key 'STM_NO'
-reduce 'TOT_ENT_EARN_AMT'
-sum 'TOT_PAY_DIR_AMT'
-decimal '16,5'

## General options
[ident('Aggr_ForPayDirHdrFtr'); jobmon_ident('Aggr_ForPayDirHdrFtr')]
## Inputs
0< 'Transformer_363:LnkPayDirHdrFtr_Part_Sort.v'
## Outputs
0> [modify (
keep
PTY_ID,DOC_ID,STM_NO,TOT_PAY_DIR_AMT;
)] 'Aggr_ForPayDirHdrFtr:LnkPayDirAggred.v'
;

#################################################################
#### STAGE: XfmPayDirHdrFtr1
## Operator
transform
## Operator options
-flag run
-name 'V0S298_CopyOfCreatePerfDtlsAFMBR_8162008_XfmPayDirHdrFtr1'

## General options
[ident('XfmPayDirHdrFtr1'); jobmon_ident('XfmPayDirHdrFtr1')]
## Inputs
0< 'Aggr_ForPayDirHdrFtr:LnkPayDirAggred.v'
## Outputs
0> [] 'XfmPayDirHdrFtr1:PayDirHdrOUT.v'
1> [] 'XfmPayDirHdrFtr1:Join4Ftr.v'
;

#################################################################
#### STAGE: PAY_DIR_HDR
## Operator
export
## Operator options
-schema record
{final_delim=end, delim=none, null_field=' ', quote=none}
(
SORT_KEY:nullable string[151];
RECORD_TYP:nullable string[4];
PTY_ID:nullable string[9];
DOC_ID:nullable string[10];
STM_NO:nullable string[10];
LINE_NUM:nullable string[10];
)
-file '[&CUFF_WRK_DIR]/MWS_AFFL_[&StmtRunCtlID]_PAYDIRHDR.txt'
-overwrite
-rejects continue

## General options
[ident('PAY_DIR_HDR'); jobmon_ident('PAY_DIR_HDR')]
## Inputs
0< 'XfmPayDirHdrFtr1:PayDirHdrOUT.v'
;

#################################################################
#### STAGE: STMT_FTR
## Operator
export
## Operator options
-schema record
{final_delim=end, delim=none, null_field=' ', quote=none}
(
SORT_KEY:nullable string[151];
RECORD_TYPE:nullable string[4];
STMT_RECP_PTY_ID:nullable string[9];
DOC_ID:nullable string[10];
STM_NO:nullable string[10];
LINE_NUM:nullable string[10];
TOT_NUM_SECS:nullable string[10];
)
-file '[&CUFF_WRK_DIR]/MWS_AFFL_[&StmtRunCtlID]_STMFTR.txt'
-overwrite
-rejects continue

## General options
[ident('STMT_FTR'); jobmon_ident('STMT_FTR')]
## Inputs
0< 'XfmStmtFtr:StmtFtrOUT.v'
;

#################################################################
#### STAGE: SEC_HDR
## Operator
export
## Operator options
-schema record
{final_delim=end, delim=none, null_field=' ', quote=none}
(
SORT_KEY:nullable string[151];
RECORD_TYP:nullable string[4];
STMT_RECP_PTY_ID:nullable string[9];
DOC_ID:nullable string[10];
STM_NO:nullable string[10];
LINE_NUM:nullable string[10];
SEC_IND:nullable string[2];
)
-file '[&CUFF_WRK_DIR]/MWS_AFFL_[&StmtRunCtlID]_SCTHDR.txt'
-overwrite
-rejects continue

## General options
[ident('SEC_HDR'); jobmon_ident('SEC_HDR')]
## Inputs
0< 'XfmRestFiles:SecHdrOUT.v'
;

#################################################################
#### STAGE: SEC_FTR
## Operator
export
## Operator options
-schema record
{final_delim=end, delim=none, null_field=' ', quote=none}
(
SORT_KEY:nullable string[151];
RECORD_TYP:nullable string[4];
STMT_RECP_PTY_ID:nullable string[9];
DOC_ID:nullable string[10];
STM_NO:nullable string[10];
LINE_NUM:nullable string[10];
SEC_IND:nullable string[2];
)
-file '[&CUFF_WRK_DIR]/MWS_AFFL_[&StmtRunCtlID]_SCTFTR.txt'
-overwrite
-rejects continue

## General options
[ident('SEC_FTR'); jobmon_ident('SEC_FTR')]
## Inputs
0< 'XfmRestFiles:SecFtrOUT.v'
;

#################################################################
#### STAGE: Aggr_TotSecs
## Operator
group
## Operator options
-hash
-key 'STMT_RECP_PTY_ID'
-key 'DOC_ID'
-key 'STM_NO'
-key 'LINE_NUM'
-countField 'TOT_NUM_SECS'

## General options
[ident('Aggr_TotSecs'); jobmon_ident('Aggr_TotSecs'); seq]
## Inputs
0< 'XfmRestFiles:StmFtr.v'
## Outputs
0> [modify (
STMT_RECP_PTY_ID:nullable int32=STMT_RECP_PTY_ID;
DOC_ID:nullable int32=DOC_ID;
STM_NO:nullable int32=STM_NO;
LINE_NUM:nullable int32=LINE_NUM;
TOT_NUM_SECS:nullable int32=TOT_NUM_SECS;
keep
STMT_RECP_PTY_ID,DOC_ID,STM_NO,LINE_NUM,
TOT_NUM_SECS;
)] 'Aggr_TotSecs:LnkTotSecs.v'
;

#################################################################
#### STAGE: XfmStmtFtr
## Operator
transform
## Operator options
-flag run
-name 'V0S334_CopyOfCreatePerfDtlsAFMBR_8162008_XfmStmtFtr'

## General options
[ident('XfmStmtFtr'); jobmon_ident('XfmStmtFtr')]
## Inputs
0< 'Aggr_TotSecs:LnkTotSecs.v'
## Outputs
0> [] 'XfmStmtFtr:StmtFtrOUT.v'
;

#################################################################
#### STAGE: Aggr_PayDir
## Operator
group
## Operator options
-hash
-key 'STMT_RECP_PTY_ID'
-key 'WRK_TTL'
-key 'WRK_ID'
-key 'ROL_TYP_CDE'
-key 'ENT_SHR'
-key 'SEC_IND'
-key 'TRAN_TYP'
-key 'ORG_DIS_REF'
-key 'MUS_USR_REF'
-key 'STM_CAT_GRP_CDE'
-key 'NA'
-key 'LIC_TYP_CDE'
-key 'CAL_LTR_SUF'
-key 'STM_SUB_CAT_IND'
-reduce 'ENT_EARN_AMT'
-sum 'TOT_DOL_AMT'
-decimal '16,5'
-reduce 'PREM_DOL'
-sum 'TOT_PREM_DOL'
-decimal '16,5'

## General options
[ident('Aggr_PayDir'); jobmon_ident('Aggr_PayDir'); seq]
## Inputs
0< 'Transformer_90:PayDir.v'
## Outputs
0> [modify (
WRK_ID:nullable int32=WRK_ID;
ENT_SHR:nullable decimal[12,3]=ENT_SHR;
keep
STMT_RECP_PTY_ID,WRK_TTL,ROL_TYP_CDE,SEC_IND,
TRAN_TYP,ORG_DIS_REF,MUS_USR_REF,STM_CAT_GRP_CDE,
NA,LIC_TYP_CDE,CAL_LTR_SUF,STM_SUB_CAT_IND,
TOT_DOL_AMT,TOT_PREM_DOL;
)] 'Aggr_PayDir:LnkPayDirAggred.v'
;

#################################################################
#### STAGE: Aggregator_358
## Operator
group
## Operator options
-hash
-key 'STMT_RECP_PTY_ID'
-key 'DOC_ID'
-key 'STM_NO'
-key 'PYBL_PTY_NA'
-key 'PYBL_PTY_IPI_NUM'
-reduce 'TOT_DOL_AMT'
-sum 'TOT_DOL_AMT'
-decimal '16,5'

## General options
[ident('Aggregator_358'); jobmon_ident('Aggregator_358'); seq]
## Inputs
0< 'XfmPayDirDtlAggr:LnkPayDirDtl.v'
## Outputs
0> [modify (
keep
STMT_RECP_PTY_ID,DOC_ID,STM_NO,PYBL_PTY_NA,
PYBL_PTY_IPI_NUM,TOT_DOL_AMT;
)] 'Aggregator_358:LnkPayDirAgg.v'
;

#################################################################
#### STAGE: Transformer_363
## Operator
transform
## Operator options
-flag run
-name 'V0S363_CopyOfCreatePerfDtlsAFMBR_8162008_Transformer_363'

## General options
[ident('Transformer_363'); jobmon_ident('Transformer_363')]
## Inputs
0< 'Aggregator_358:LnkPayDirAgg.v'
## Outputs
0> [] 'Transformer_363:PayDirOUT.v'
1> [] 'Transformer_363:LnkPayDirHdrFtr.v'
2> [] 'Transformer_363:LnkPayDirHdrFtr2.v'
;

#################################################################
#### STAGE: Sequential_File_368
## Operator
export
## Operator options
-schema record
{final_delim=end, delim=',', quote=double}
(
SORT_KEY:nullable string[151];
RECORD_TYP:nullable string[4];
STMT_RECP_PTY_ID:nullable string[9];
SEC_IND:nullable string[2];
TRAN_TYP:nullable string[2];
STM_CAT:nullable string[2];
STM_SUB_CAT_IND:nullable string[1];
STM_SUB_CAT_LBL:nullable string[50];
TOT_DOL_AMT:nullable string[16];
TOT_DOL_AMT_Org:nullable decimal[16,5];
TOT_DOL_AMT_Rnd:nullable decimal[16,2];
Tot_dol_Mantissa:nullable string[max=2];
Tot_Dol_prec:nullable string[max=90];
)
-file '[&CUFF_WRK_DIR]/PerfSumTest.txt'
-overwrite
-rejects continue
-firstLineColumnNames

## General options
[ident('Sequential_File_368'); jobmon_ident('Sequential_File_368')]
## Inputs
0< 'XfmPerfSum:DSLink369.v'
;

#################################################################
#### STAGE: NullToValues
## Operator
transform
## Operator options
-flag run
-name 'V79S0_CopyOfCreatePerfDtlsAFMBR_8162008_NullToValues'

## General options
[ident('NullToValues'); jobmon_ident('NullToValues')]
## Inputs
0< 'Jn_CalLtrWPDtls:LnkCL_WPSDtls.v'
## Outputs
0> [] 'NullToValues:LnkAfmbr.v'
;

#################################################################
#### STAGE: Jn_CalLtrWPDtls
## Operator
leftouterjoin
## Operator options
-key 'MUS_USR_PTY_ID'

## General options
[ident('Jn_CalLtrWPDtls'); jobmon_ident('Jn_CalLtrWPDtls'); seq]
## Inputs
0< 'Copy_of_XfmCheckNull1:LnkAfmbr.v'
1< 'CallLtrDtls:Get_CalLtrDtls.v'
## Outputs
0> [modify (
keep
CAL_LTR_SUF,MUS_USR_PTY_ID,NA,PTY_EFF_STT_DT,
PTY_EFF_END_DT,PTY_NA_TYP_CDE,ENT_EARN_LN_ID,ENT_EARN_PTY_ID,
ENT_EARN_AMT,PREM_FNL_CR,RYLT_LN_ID,ORG_DIS_ID,
ADJ_TRIG_ID,MUS_USR_TYP_CDE,LIC_TYP_CDE,DMSTC_CR_VAL,
WRK_PERF_SHR_ID,SHR_OWN_PTY_NA_ID,PAYBL_OWN_PTY_NA_ID,SHR_ADM_PTY_NA_ID,
ENT_SHR,ROL_TYP_CDE,WRK_PERF_ID,WRK_ID,
WRK_TTL,PERF_HDR_ID,SER_TTL,PGM_TTL,
PGM_STT_DT,PGM_END_DT,LKP_LIC_TYP_CDE,PTY_NA_ID;
)] 'Jn_CalLtrWPDtls:LnkCL_WPSDtls.v'
;

#################################################################
#### STAGE: CallLtrDtls
## Operator
oraread
## Operator options
-dboptions '{user=[&DB_USER],password=[&DB_PWD]}'
-server '[&DB_SERVER]'
-query 'select NVL(PTY_NA.CAL_LTR_SUF,\'All\') AS CAL_LTR_SUF, pty.PTY_ID AS MUS_USR_PTY_ID, pty_na.na as NA, NVL(pty_na.STT_DT, \'1-JAN-1900\') AS PTY_EFF_STT_DT, NVL(pty_na.END_DT,\'31-DEC-9999\') PTY_EFF_END_DT, pty_na.pty_na_typ_cde PTY_NA_TYP_CDE , Pty_na_id
FROM PTY, PTY_NA
WHERE PTY.PTY_TYP_CDE = \'MUSUS\'
AND PTY.PTY_ID = PTY_NA.PTY_ID
AND PTY_NA.PTY_NA_TYP_CDE = \'CL\'
AND PTY.DEL_FL=\'N\'
AND PTY_NA.DEL_FL=\'N\''

## General options
[ident('CallLtrDtls'); jobmon_ident('CallLtrDtls')]
## Outputs
0> [modify (
CAL_LTR_SUF:nullable string[max=3]=CAL_LTR_SUF;
MUS_USR_PTY_ID:nullable int32=MUS_USR_PTY_ID;
NA:nullable string[max=90]=NA;
PTY_EFF_STT_DT:nullable timestamp=PTY_EFF_STT_DT;
PTY_EFF_END_DT:nullable timestamp=PTY_EFF_END_DT;
PTY_NA_TYP_CDE:nullable string[max=2]=PTY_NA_TYP_CDE;
PTY_NA_ID:not_nullable decimal[15,0]=PTY_NA_ID;
keep
CAL_LTR_SUF,MUS_USR_PTY_ID,NA,PTY_EFF_STT_DT,
PTY_EFF_END_DT,PTY_NA_TYP_CDE,PTY_NA_ID;
)] 'CallLtrDtls:Get_CalLtrDtls.v'
;

#################################################################
#### STAGE: Copy_of_XfmCheckNull1
## Operator
transform
## Operator options
-flag run
-name 'V79S4_CopyOfCreatePerfDtlsAFMBR_8162008_Copy_of_XfmCheckNull1'

## General options
[ident('Copy_of_XfmCheckNull1'); jobmon_ident('Copy_of_XfmCheckNull1')]
## Inputs
0< 'Copy_of_AFMBR_SQL:LnkAfmbrInfoIN.v'
## Outputs
0> [] 'Copy_of_XfmCheckNull1:LnkAfmbr.v'
;

#################################################################
#### STAGE: Copy_of_AFMBR_SQL
## Operator
oraread
## Operator options
-dboptions '{user=[&DB_USER],password=[&DB_PWD]}'
-server '[&DB_SERVER]'
-query 'SELECT /*+ Ordered */
eel.ENT_EARN_LN_ID, eel.ENT_EARN_PTY_ID,
eel.ENT_EARN_AMT, nvl(eel.PREM_FNL_CR, 0) PREM_FNL_CR,
rl.RYLT_LN_ID, rl.ORG_DIS_ID,
rl.ADJ_TRIG_ID, rl.MUS_USR_PTY_ID,
rl.MUS_USR_TYP_CDE, rl.LIC_TYP_CDE,
d.DMSTC_CR_VAL, wps.WRK_PERF_SHR_ID,
wps.SHR_OWN_PTY_NA_ID, wps.PAYBL_OWN_PTY_NA_ID,
wps.SHR_ADM_PTY_NA_ID, wps.ENT_SHR,
wps.ROL_TYP_CDE, wp.WRK_PERF_ID,
wp.WRK_ID, wp.WRK_TTL,
ph.PERF_HDR_ID, nvl(ph.SER_TTL,\'0\') SER_TTL,
nvl(ph.PGM_TTL,\'0\') PGM_TTL, ph.PGM_STT_DT,
ph.PGM_END_DT
FROM
ENT_EARN_LN eel, RYLT_LN rl,
DIS d, WRK_PERF_SHR wps,
WRK_PERF wp, PERF_HDR ph
WHERE
eel.RYLT_RUN_CTL_ID = [&DedcRunCtrlID]
AND eel.ent_earn_ln_sta_cde = \'CO\'
AND eel.rylt_ln_id = rl.rylt_ln_id
AND rl.rylt_ln_sta_cde = \'EA\'
AND rl.dis_id = d.dis_id
AND rl.wrk_perf_shr_id = wps.wrk_perf_shr_id
AND wps.wrk_perf_id = wp.wrk_perf_id
AND wp.perf_hdr_id = ph.perf_hdr_id
AND wp.del_fl=\'N\'
AND eel.del_fl=\'N\'
AND rl.del_fl=\'N\'
AND d.del_fl=\'N\'
AND ph.del_fl=\'N\'
AND wps.del_fl=\'N\'

'

## General options
[ident('Copy_of_AFMBR_SQL'); jobmon_ident('Copy_of_AFMBR_SQL')]
## Outputs
0> [modify (
ENT_EARN_LN_ID:not_nullable decimal[15,0]=ENT_EARN_LN_ID;
ENT_EARN_PTY_ID:nullable int32=ENT_EARN_PTY_ID;
ENT_EARN_AMT:nullable decimal[16,5]=ENT_EARN_AMT;
PREM_FNL_CR:nullable decimal[16,5]=PREM_FNL_CR;
RYLT_LN_ID:not_nullable decimal[15,0]=RYLT_LN_ID;
ORG_DIS_ID:nullable int32=ORG_DIS_ID;
ADJ_TRIG_ID:nullable decimal[15,0]=ADJ_TRIG_ID;
MUS_USR_PTY_ID:nullable int32=MUS_USR_PTY_ID;
MUS_USR_TYP_CDE:nullable string[max=5]=MUS_USR_TYP_CDE;
LIC_TYP_CDE:nullable string[max=4]=LIC_TYP_CDE;
DMSTC_CR_VAL:nullable decimal[16,5]=DMSTC_CR_VAL;
WRK_PERF_SHR_ID:not_nullable decimal[15,0]=WRK_PERF_SHR_ID;
SHR_OWN_PTY_NA_ID:nullable decimal[15,0]=SHR_OWN_PTY_NA_ID;
PAYBL_OWN_PTY_NA_ID:nullable decimal[15,0]=PAYBL_OWN_PTY_NA_ID;
SHR_ADM_PTY_NA_ID:nullable decimal[15,0]=SHR_ADM_PTY_NA_ID;
ENT_SHR:nullable decimal[7,4]=ENT_SHR;
ROL_TYP_CDE:nullable string[max=2]=ROL_TYP_CDE;
WRK_PERF_ID:not_nullable decimal[15,0]=WRK_PERF_ID;
WRK_ID:nullable decimal[11,0]=WRK_ID;
WRK_TTL:nullable string[max=50]=WRK_TTL;
PERF_HDR_ID:not_nullable decimal[15,0]=PERF_HDR_ID;
SER_TTL:nullable string[max=50]=SER_TTL;
PGM_TTL:nullable string[max=50]=PGM_TTL;
PGM_STT_DT:nullable timestamp=PGM_STT_DT;
PGM_END_DT:nullable timestamp=PGM_END_DT;
keep
ENT_EARN_LN_ID,ENT_EARN_PTY_ID,ENT_EARN_AMT,PREM_FNL_CR,
RYLT_LN_ID,ORG_DIS_ID,ADJ_TRIG_ID,MUS_USR_PTY_ID,
MUS_USR_TYP_CDE,LIC_TYP_CDE,DMSTC_CR_VAL,WRK_PERF_SHR_ID,
SHR_OWN_PTY_NA_ID,PAYBL_OWN_PTY_NA_ID,SHR_ADM_PTY_NA_ID,ENT_SHR,
ROL_TYP_CDE,WRK_PERF_ID,WRK_ID,WRK_TTL,
PERF_HDR_ID,SER_TTL,PGM_TTL,PGM_STT_DT,
PGM_END_DT;
)] 'Copy_of_AFMBR_SQL:LnkAfmbrInfoIN.v'
;

#################################################################
#### STAGE: Aggr_ForPayDirHdrFtr2
## Operator
group
## Operator options
-sort
-key 'PTY_ID'
-key 'DOC_ID'
-key 'STM_NO'
-countField 'TOT_CNT_PAY_DIR_RECS'

## General options
[ident('Aggr_ForPayDirHdrFtr2'); jobmon_ident('Aggr_ForPayDirHdrFtr2')]
## Inputs
0< 'Transformer_363:LnkPayDirHdrFtr2.v'
## Outputs
0> [modify (
TOT_CNT_PAY_DIR_RECS:nullable int32=TOT_CNT_PAY_DIR_RECS;
keep
PTY_ID,DOC_ID,STM_NO;
)] 'Aggr_ForPayDirHdrFtr2:LnkPayDirAggred2.v'
;

#################################################################
#### STAGE: Copy_of_PAY_DIR_FTR
## Operator
export
## Operator options
-schema record
{final_delim=end, delim=none, null_field=' ', quote=none}
(
SORT_KEY:nullable string[151];
RECORD_TYP:nullable string[4];
PTY_ID:nullable string[9];
DOC_ID:nullable string[10];
STM_NO:nullable string[10];
LINE_NUM:nullable string[10];
TOT_PAY_DIR_AMT:nullable string[16];
TOT_CNT_PAY_DIR_RECS:nullable string[10];
)
-file '[&CUFF_WRK_DIR]/MWS_AFFL_[&StmtRunCtlID]_PAYDIRFTR.txt'
-overwrite
-rejects continue

## General options
[ident('Copy_of_PAY_DIR_FTR'); jobmon_ident('Copy_of_PAY_DIR_FTR')]
## Inputs
0< 'XfmPayDirFtr:PayDirFtrOUT.v'
;

#################################################################
#### STAGE: XfmPayDirFtr
## Operator
transform
## Operator options
-flag run
-name 'V81S2_CopyOfCreatePerfDtlsAFMBR_8162008_XfmPayDirFtr'

## General options
[ident('XfmPayDirFtr'); jobmon_ident('XfmPayDirFtr')]
## Inputs
0< 'Join_383:LnkPayDirAggred.v'
## Outputs
0> [] 'XfmPayDirFtr:PayDirFtrOUT.v'
;

#################################################################
#### STAGE: Join_383
## Operator
innerjoin
## Operator options
-key 'PTY_ID'
-key 'DOC_ID'
-key 'STM_NO'

## General options
[ident('Join_383'); jobmon_ident('Join_383')]
## Inputs
0< 'XfmPayDirHdrFtr1:Join4Ftr.v'
1< 'XfmPayDirHdrFtr2:PayDirFTROUT.v'
## Outputs
0> [modify (
PTY_ID:nullable dfloat=PTY_ID;
DOC_ID:nullable int32=DOC_ID;
STM_NO:nullable int32=STM_NO;
TOT_PAY_DIR_AMT:nullable decimal[16,5]=TOT_PAY_DIR_AMT;
keep
LINE_NUM,TOT_CNT_PAY_DIR_RECS;
)] 'Join_383:LnkPayDirAggred.v'
;

#################################################################
#### STAGE: XfmPayDirHdrFtr2
## Operator
transform
## Operator options
-flag run
-name 'V82S0_CopyOfCreatePerfDtlsAFMBR_8162008_XfmPayDirHdrFtr2'

## General options
[ident('XfmPayDirHdrFtr2'); jobmon_ident('XfmPayDirHdrFtr2')]
## Inputs
0< 'Aggr_ForPayDirHdrFtr2:LnkPayDirAggred2.v'
## Outputs
0> [] 'XfmPayDirHdrFtr2:PayDirFTROUT.v'
;

Thanks again... :-)
vishal
Top
Post Reply

Return to “IBM<sup>®</sup> DataStage Enterprise Edition (Formerly Parallel Extender/PX)”