471: -- convention followed for UPDATE_NAME - scriptname suffix with version
472: */
473:
474:
475: ad_parallel_updates_pkg.initialize_rowid_range(
476: ad_parallel_updates_pkg.ROWID_RANGE,
477: l_table_owner,
478: l_table_name,
479: l_update_name,
472: */
473:
474:
475: ad_parallel_updates_pkg.initialize_rowid_range(
476: ad_parallel_updates_pkg.ROWID_RANGE,
477: l_table_owner,
478: l_table_name,
479: l_update_name,
480: l_worker_id,
480: l_worker_id,
481: l_num_workers,
482: l_batch_size, 0);
483:
484: ad_parallel_updates_pkg.get_rowid_range(
485: l_start_rowid,
486: l_END_rowid,
487: l_any_rows_to_process,
488: l_batch_size,
511: fnd_file.put_line(FND_FILE.LOG, l_rows_processed ||' rows updated ');
512:
513: END;
514:
515: ad_parallel_updates_pkg.processed_rowid_range(l_rows_processed,l_END_rowid);
516:
517: COMMIT;
518:
519:
517: COMMIT;
518:
519:
520: -- get new range of rowids
521: ad_parallel_updates_pkg.get_rowid_range(
522: l_start_rowid,
523: l_end_rowid,
524: l_any_rows_to_process,
525: l_batch_size,
600: -- the change.
601: -- convention followed for UPDATE_NAME - scriptname suffix with version
602: */
603:
604: ad_parallel_updates_pkg.initialize_rowid_range(
605: ad_parallel_updates_pkg.ROWID_RANGE,
606: l_table_owner,
607: l_table_name,
608: l_update_name,
601: -- convention followed for UPDATE_NAME - scriptname suffix with version
602: */
603:
604: ad_parallel_updates_pkg.initialize_rowid_range(
605: ad_parallel_updates_pkg.ROWID_RANGE,
606: l_table_owner,
607: l_table_name,
608: l_update_name,
609: l_worker_id,
609: l_worker_id,
610: l_num_workers,
611: l_batch_size, 0);
612:
613: ad_parallel_updates_pkg.get_rowid_range(
614: l_start_rowid,
615: l_END_rowid,
616: l_any_rows_to_process,
617: l_batch_size,
638: fnd_file.put_line(FND_FILE.LOG, l_rows_processed ||' rows updated ');
639:
640: END;
641:
642: ad_parallel_updates_pkg.processed_rowid_range(l_rows_processed,l_END_rowid);
643:
644: COMMIT;
645:
646:
644: COMMIT;
645:
646:
647: -- get new range of rowids
648: ad_parallel_updates_pkg.get_rowid_range(
649: l_start_rowid,
650: l_end_rowid,
651: l_any_rows_to_process,
652: l_batch_size,
745: -- the change.
746: -- convention followed for UPDATE_NAME - scriptname suffix with version
747: */
748:
749: ad_parallel_updates_pkg.initialize_rowid_range(
750: ad_parallel_updates_pkg.ROWID_RANGE,
751: l_table_owner,
752: l_table_name,
753: l_update_name,
746: -- convention followed for UPDATE_NAME - scriptname suffix with version
747: */
748:
749: ad_parallel_updates_pkg.initialize_rowid_range(
750: ad_parallel_updates_pkg.ROWID_RANGE,
751: l_table_owner,
752: l_table_name,
753: l_update_name,
754: l_worker_id,
754: l_worker_id,
755: l_num_workers,
756: l_batch_size, 0);
757:
758: ad_parallel_updates_pkg.get_rowid_range(
759: l_start_rowid,
760: l_END_rowid,
761: l_any_rows_to_process,
762: l_batch_size,
798: fnd_file.put_line(FND_FILE.LOG, l_rows_processed ||' rows updated ');
799:
800: END;
801:
802: ad_parallel_updates_pkg.processed_rowid_range(l_rows_processed,l_END_rowid);
803:
804: COMMIT;
805:
806:
804: COMMIT;
805:
806:
807: -- get new range of rowids
808: ad_parallel_updates_pkg.get_rowid_range(
809: l_start_rowid,
810: l_end_rowid,
811: l_any_rows_to_process,
812: l_batch_size,