APPS.FA_UPGHARNESS_PKG dependencies on AD_PARALLEL_UPDATES_PKG

Line 370: ad_parallel_updates_pkg.initialize_rowid_range(

366: begin
367:
368: l_batch_size := p_batch_size;
369:
370: ad_parallel_updates_pkg.initialize_rowid_range(
371: ad_parallel_updates_pkg.ROWID_RANGE,
372: p_table_owner,
373: l_table_name1,
374: p_script_name,

Line 371: ad_parallel_updates_pkg.ROWID_RANGE,

367:
368: l_batch_size := p_batch_size;
369:
370: ad_parallel_updates_pkg.initialize_rowid_range(
371: ad_parallel_updates_pkg.ROWID_RANGE,
372: p_table_owner,
373: l_table_name1,
374: p_script_name,
375: p_worker_id,

Line 379: ad_parallel_updates_pkg.get_rowid_range(

375: p_worker_id,
376: p_workers_num,
377: l_batch_size, 0);
378:
379: ad_parallel_updates_pkg.get_rowid_range(
380: l_start_rowid,
381: l_end_rowid,
382: l_any_rows_to_process,
383: l_batch_size,

Line 399: ad_parallel_updates_pkg.processed_rowid_range(

395: );
396:
397: l_rows_processed := l_batch_size;
398:
399: ad_parallel_updates_pkg.processed_rowid_range(
400: l_rows_processed,
401: l_end_rowid);
402:
403: commit;

Line 408: ad_parallel_updates_pkg.get_rowid_range(

404:
405: --
406: -- get new range of rowids
407: --
408: ad_parallel_updates_pkg.get_rowid_range(
409: l_start_rowid,
410: l_end_rowid,
411: l_any_rows_to_process,
412: l_batch_size,

Line 426: ad_parallel_updates_pkg.initialize_rowid_range(

422: into l_group_books
423: from fa_book_controls
424: where allow_group_deprn_flag = 'Y';
425:
426: ad_parallel_updates_pkg.initialize_rowid_range(
427: ad_parallel_updates_pkg.ROWID_RANGE,
428: p_table_owner,
429: l_table_name2,
430: p_script_name,

Line 427: ad_parallel_updates_pkg.ROWID_RANGE,

423: from fa_book_controls
424: where allow_group_deprn_flag = 'Y';
425:
426: ad_parallel_updates_pkg.initialize_rowid_range(
427: ad_parallel_updates_pkg.ROWID_RANGE,
428: p_table_owner,
429: l_table_name2,
430: p_script_name,
431: p_worker_id,

Line 435: ad_parallel_updates_pkg.get_rowid_range(

431: p_worker_id,
432: p_workers_num,
433: l_batch_size, 0);
434:
435: ad_parallel_updates_pkg.get_rowid_range(
436: l_start_rowid,
437: l_end_rowid,
438: l_any_rows_to_process,
439: l_batch_size,

Line 467: ad_parallel_updates_pkg.processed_rowid_range(

463: );
464:
465: l_rows_processed := l_batch_size;
466:
467: ad_parallel_updates_pkg.processed_rowid_range(
468: l_rows_processed,
469: l_end_rowid);
470:
471:

Line 477: ad_parallel_updates_pkg.get_rowid_range(

473:
474: --
475: -- get new range of rowids
476: --
477: ad_parallel_updates_pkg.get_rowid_range(
478: l_start_rowid,
479: l_end_rowid,
480: l_any_rows_to_process,
481: l_batch_size,

Line 655: ad_parallel_updates_pkg.initialize_rowid_range(

651:
652: if (p_mode <> 'downtime') or (l_deprn_run > 0) then
653:
654: -- for deprn table
655: ad_parallel_updates_pkg.initialize_rowid_range(
656: ad_parallel_updates_pkg.ROWID_RANGE,
657: p_table_owner,
658: l_table_name1,
659: p_script_name,

Line 656: ad_parallel_updates_pkg.ROWID_RANGE,

652: if (p_mode <> 'downtime') or (l_deprn_run > 0) then
653:
654: -- for deprn table
655: ad_parallel_updates_pkg.initialize_rowid_range(
656: ad_parallel_updates_pkg.ROWID_RANGE,
657: p_table_owner,
658: l_table_name1,
659: p_script_name,
660: p_worker_id,

Line 664: ad_parallel_updates_pkg.get_rowid_range(

660: p_worker_id,
661: p_workers_num,
662: l_batch_size, 0);
663:
664: ad_parallel_updates_pkg.get_rowid_range(
665: l_start_rowid,
666: l_end_rowid,
667: l_any_rows_to_process,
668: l_batch_size,

Line 685: ad_parallel_updates_pkg.processed_rowid_range(

681: );
682:
683: l_rows_processed := l_batch_size;
684:
685: ad_parallel_updates_pkg.processed_rowid_range(
686: l_rows_processed,
687: l_end_rowid);
688:
689: commit;

Line 694: ad_parallel_updates_pkg.get_rowid_range(

690:
691: --
692: -- get new range of rowids
693: --
694: ad_parallel_updates_pkg.get_rowid_range(
695: l_start_rowid,
696: l_end_rowid,
697: l_any_rows_to_process,
698: l_batch_size,

Line 714: ad_parallel_updates_pkg.initialize_rowid_range(

710: -- threaded
711: if (p_mode <> 'downtime') and (p_worker_id = 1) then
712:
713: -- for deferred table
714: ad_parallel_updates_pkg.initialize_rowid_range(
715: ad_parallel_updates_pkg.ROWID_RANGE,
716: p_table_owner,
717: l_table_name2,
718: p_script_name,

Line 715: ad_parallel_updates_pkg.ROWID_RANGE,

711: if (p_mode <> 'downtime') and (p_worker_id = 1) then
712:
713: -- for deferred table
714: ad_parallel_updates_pkg.initialize_rowid_range(
715: ad_parallel_updates_pkg.ROWID_RANGE,
716: p_table_owner,
717: l_table_name2,
718: p_script_name,
719: 1, -- p_worker_id

Line 723: ad_parallel_updates_pkg.get_rowid_range(

719: 1, -- p_worker_id
720: 1, -- p_workers_num
721: l_batch_size, 0);
722:
723: ad_parallel_updates_pkg.get_rowid_range(
724: l_start_rowid,
725: l_end_rowid,
726: l_any_rows_to_process,
727: l_batch_size,

Line 743: ad_parallel_updates_pkg.processed_rowid_range(

739: );
740:
741: l_rows_processed := l_batch_size;
742:
743: ad_parallel_updates_pkg.processed_rowid_range(
744: l_rows_processed,
745: l_end_rowid);
746:
747: commit;

Line 752: ad_parallel_updates_pkg.get_rowid_range(

748:
749: --
750: -- get new range of rowids
751: --
752: ad_parallel_updates_pkg.get_rowid_range(
753: l_start_rowid,
754: l_end_rowid,
755: l_any_rows_to_process,
756: l_batch_size,