2127:
2128: -- AD Parallel framework Manager processing
2129:
2130: --Purge all the info from ad processing tables
2131: ad_parallel_updates_pkg.purge_processed_units
2132: (X_owner => 'FEM',
2133: X_table => 'FEM_INTG_OGL_CCID_MAP',
2134: X_script => FEM_INTG_DIM_RULE_ENG_PKG.pv_coa_id);
2135:
2132: (X_owner => 'FEM',
2133: X_table => 'FEM_INTG_OGL_CCID_MAP',
2134: X_script => FEM_INTG_DIM_RULE_ENG_PKG.pv_coa_id);
2135:
2136: ad_parallel_updates_pkg.delete_update_information
2137: (X_update_type => ad_parallel_updates_pkg.ROWID_RANGE,
2138: X_owner => 'FEM',
2139: X_table => 'FEM_INTG_OGL_CCID_MAP',
2140: X_script => FEM_INTG_DIM_RULE_ENG_PKG.pv_coa_id);
2133: X_table => 'FEM_INTG_OGL_CCID_MAP',
2134: X_script => FEM_INTG_DIM_RULE_ENG_PKG.pv_coa_id);
2135:
2136: ad_parallel_updates_pkg.delete_update_information
2137: (X_update_type => ad_parallel_updates_pkg.ROWID_RANGE,
2138: X_owner => 'FEM',
2139: X_table => 'FEM_INTG_OGL_CCID_MAP',
2140: X_script => FEM_INTG_DIM_RULE_ENG_PKG.pv_coa_id);
2141:
4050:
4051: -- AD Parallel framework Manager processing
4052:
4053: --Purge all the info from ad processing tables
4054: ad_parallel_updates_pkg.purge_processed_units
4055: (X_owner => 'FEM',
4056: X_table => 'FEM_INTG_OGL_CCID_MAP',
4057: X_script => FEM_INTG_DIM_RULE_ENG_PKG.pv_coa_id);
4058:
4055: (X_owner => 'FEM',
4056: X_table => 'FEM_INTG_OGL_CCID_MAP',
4057: X_script => FEM_INTG_DIM_RULE_ENG_PKG.pv_coa_id);
4058:
4059: ad_parallel_updates_pkg.delete_update_information
4060: (X_update_type => ad_parallel_updates_pkg.ROWID_RANGE,
4061: X_owner => 'FEM',
4062: X_table => 'FEM_INTG_OGL_CCID_MAP',
4063: X_script => FEM_INTG_DIM_RULE_ENG_PKG.pv_coa_id);
4056: X_table => 'FEM_INTG_OGL_CCID_MAP',
4057: X_script => FEM_INTG_DIM_RULE_ENG_PKG.pv_coa_id);
4058:
4059: ad_parallel_updates_pkg.delete_update_information
4060: (X_update_type => ad_parallel_updates_pkg.ROWID_RANGE,
4061: X_owner => 'FEM',
4062: X_table => 'FEM_INTG_OGL_CCID_MAP',
4063: X_script => FEM_INTG_DIM_RULE_ENG_PKG.pv_coa_id);
4064:
4698: --
4699:
4700: v_update_name := p_coa_id;
4701:
4702: ad_parallel_updates_pkg.initialize_rowid_range( ad_parallel_updates_pkg.ROWID_RANGE,
4703: v_table_owner,
4704: v_table_name,
4705: v_update_name,
4706: p_Worker_Id,
4707: p_Num_Workers,
4708: p_batch_size,
4709: 0);
4710:
4711: ad_parallel_updates_pkg.get_rowid_range( v_start_rowid,
4712: v_end_rowid,
4713: v_any_rows_to_process,
4714: p_batch_size,
4715: TRUE);
4851:
4852: CLOSE v_ccid_cur;
4853: -- end FEM update logic
4854: v_rows_processed := SQL%ROWCOUNT;
4855: ad_parallel_updates_pkg.processed_rowid_range( v_rows_processed,
4856: v_end_rowid);
4857: COMMIT;
4858:
4859: ad_parallel_updates_pkg.get_rowid_range( v_start_rowid,
4855: ad_parallel_updates_pkg.processed_rowid_range( v_rows_processed,
4856: v_end_rowid);
4857: COMMIT;
4858:
4859: ad_parallel_updates_pkg.get_rowid_range( v_start_rowid,
4860: v_end_rowid,
4861: v_any_rows_to_process,
4862: p_batch_size,
4863: FALSE);