583: BEGIN -- {begin1
584:
585: l_audit_date := to_date(p_audit_date,'YYYY/MM/DD HH24:MI:SS');
586: FND_FILE.Put_Line(fnd_file.log, 'p_audit_date=' || p_audit_date);
587: ad_parallel_updates_pkg.initialize_rowid_range(
588: ad_parallel_updates_pkg.ROWID_RANGE,
589: l_table_owner,
590: l_table_name,
591: l_update_name || p_update_date, -- to ensure it is rerunnable
584:
585: l_audit_date := to_date(p_audit_date,'YYYY/MM/DD HH24:MI:SS');
586: FND_FILE.Put_Line(fnd_file.log, 'p_audit_date=' || p_audit_date);
587: ad_parallel_updates_pkg.initialize_rowid_range(
588: ad_parallel_updates_pkg.ROWID_RANGE,
589: l_table_owner,
590: l_table_name,
591: l_update_name || p_update_date, -- to ensure it is rerunnable
592: x_worker_id,
592: x_worker_id,
593: x_num_workers,
594: x_batch_size, 0);
595:
596: ad_parallel_updates_pkg.get_rowid_range(
597: l_start_rowid,
598: l_end_rowid,
599: l_any_rows_to_process,
600: x_batch_size,
2315: END LOOP; -- } Loop2
2316:
2317: CLOSE c_sr_current;
2318:
2319: ad_parallel_updates_pkg.processed_rowid_range(
2320: l_loop_counter,
2321: l_end_rowid);
2322:
2323: --
2327: --
2328:
2329: -- get new range of rowids
2330: --
2331: ad_parallel_updates_pkg.get_rowid_range(
2332: l_start_rowid,
2333: l_end_rowid,
2334: l_any_rows_to_process,
2335: x_batch_size,