82:
83: -- AD Parallel framework Manager processing
84:
85: --Purge all the info from ad processing tables
86: ad_parallel_updates_pkg.purge_processed_units(X_owner => 'GCS',
87: X_table => 'GCS_CONS_ENG_RUNS',
88: X_script => p_key);
89:
90: ad_parallel_updates_pkg.delete_update_information(X_update_type => ad_parallel_updates_pkg.ROWID_RANGE,
86: ad_parallel_updates_pkg.purge_processed_units(X_owner => 'GCS',
87: X_table => 'GCS_CONS_ENG_RUNS',
88: X_script => p_key);
89:
90: ad_parallel_updates_pkg.delete_update_information(X_update_type => ad_parallel_updates_pkg.ROWID_RANGE,
91: X_owner => 'GCS',
92: X_table => 'GCS_CONS_ENG_RUNS',
93: X_script => p_key);
94:
325: AND gcer.most_recent_flag = 'Y'
326: AND gcer.run_entity_id = p_consolidation_entity;
327:
328: -- To initialize the rowid range
329: ad_parallel_updates_pkg.initialize_rowid_range( ad_parallel_updates_pkg.ROWID_RANGE,
330: v_table_owner,
331: v_table_name,
332: p_key,
333: p_Worker_Id,
335: p_batch_size,
336: 0);
337:
338: -- To get its repective rowid range
339: ad_parallel_updates_pkg.get_rowid_range( v_start_rowid,
340: v_end_rowid,
341: v_any_rows_to_process,
342: p_batch_size,
343: TRUE);
429: END LOOP; -- enf of outer cursor(c_purge_cons_entity) loop
430: fnd_file.put_line(fnd_file.log, '+------------------------------------+--------------------------+-------------------------------------------------------------------------------------------+');
431: CLOSE c_purge_cons_entity;
432: --To update number rows processed so far
433: ad_parallel_updates_pkg.processed_rowid_range( v_rows_processed, v_end_rowid);
434: COMMIT;
435: --To get next of rows for processing
436: ad_parallel_updates_pkg.get_rowid_range( v_start_rowid,
437: v_end_rowid,
432: --To update number rows processed so far
433: ad_parallel_updates_pkg.processed_rowid_range( v_rows_processed, v_end_rowid);
434: COMMIT;
435: --To get next of rows for processing
436: ad_parallel_updates_pkg.get_rowid_range( v_start_rowid,
437: v_end_rowid,
438: v_any_rows_to_process,
439: p_batch_size,
440: FALSE);