DBA Data[Home] [Help]

APPS.FA_UPGHARNESS_PKG dependencies on AD_PARALLEL_UPDATES_PKG

Line 313: ad_parallel_updates_pkg.initialize_rowid_range(

309: begin
310:
311: l_batch_size := p_batch_size;
312:
313: ad_parallel_updates_pkg.initialize_rowid_range(
314: ad_parallel_updates_pkg.ROWID_RANGE,
315: p_table_owner,
316: l_table_name1,
317: p_script_name,

Line 314: ad_parallel_updates_pkg.ROWID_RANGE,

310:
311: l_batch_size := p_batch_size;
312:
313: ad_parallel_updates_pkg.initialize_rowid_range(
314: ad_parallel_updates_pkg.ROWID_RANGE,
315: p_table_owner,
316: l_table_name1,
317: p_script_name,
318: p_worker_id,

Line 322: ad_parallel_updates_pkg.get_rowid_range(

318: p_worker_id,
319: p_workers_num,
320: l_batch_size, 0);
321:
322: ad_parallel_updates_pkg.get_rowid_range(
323: l_start_rowid,
324: l_end_rowid,
325: l_any_rows_to_process,
326: l_batch_size,

Line 342: ad_parallel_updates_pkg.processed_rowid_range(

338: );
339:
340: l_rows_processed := l_batch_size;
341:
342: ad_parallel_updates_pkg.processed_rowid_range(
343: l_rows_processed,
344: l_end_rowid);
345:
346: commit;

Line 351: ad_parallel_updates_pkg.get_rowid_range(

347:
348: --
349: -- get new range of rowids
350: --
351: ad_parallel_updates_pkg.get_rowid_range(
352: l_start_rowid,
353: l_end_rowid,
354: l_any_rows_to_process,
355: l_batch_size,

Line 369: ad_parallel_updates_pkg.initialize_rowid_range(

365: into l_group_books
366: from fa_book_controls
367: where allow_group_deprn_flag = 'Y';
368:
369: ad_parallel_updates_pkg.initialize_rowid_range(
370: ad_parallel_updates_pkg.ROWID_RANGE,
371: p_table_owner,
372: l_table_name2,
373: p_script_name,

Line 370: ad_parallel_updates_pkg.ROWID_RANGE,

366: from fa_book_controls
367: where allow_group_deprn_flag = 'Y';
368:
369: ad_parallel_updates_pkg.initialize_rowid_range(
370: ad_parallel_updates_pkg.ROWID_RANGE,
371: p_table_owner,
372: l_table_name2,
373: p_script_name,
374: p_worker_id,

Line 378: ad_parallel_updates_pkg.get_rowid_range(

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

Line 410: ad_parallel_updates_pkg.processed_rowid_range(

406: );
407:
408: l_rows_processed := l_batch_size;
409:
410: ad_parallel_updates_pkg.processed_rowid_range(
411: l_rows_processed,
412: l_end_rowid);
413:
414:

Line 420: ad_parallel_updates_pkg.get_rowid_range(

416:
417: --
418: -- get new range of rowids
419: --
420: ad_parallel_updates_pkg.get_rowid_range(
421: l_start_rowid,
422: l_end_rowid,
423: l_any_rows_to_process,
424: l_batch_size,

Line 598: ad_parallel_updates_pkg.initialize_rowid_range(

594:
595: if (p_mode <> 'downtime') or (l_deprn_run > 0) then
596:
597: -- for deprn table
598: ad_parallel_updates_pkg.initialize_rowid_range(
599: ad_parallel_updates_pkg.ROWID_RANGE,
600: p_table_owner,
601: l_table_name1,
602: p_script_name,

Line 599: ad_parallel_updates_pkg.ROWID_RANGE,

595: if (p_mode <> 'downtime') or (l_deprn_run > 0) then
596:
597: -- for deprn table
598: ad_parallel_updates_pkg.initialize_rowid_range(
599: ad_parallel_updates_pkg.ROWID_RANGE,
600: p_table_owner,
601: l_table_name1,
602: p_script_name,
603: p_worker_id,

Line 607: ad_parallel_updates_pkg.get_rowid_range(

603: p_worker_id,
604: p_workers_num,
605: l_batch_size, 0);
606:
607: ad_parallel_updates_pkg.get_rowid_range(
608: l_start_rowid,
609: l_end_rowid,
610: l_any_rows_to_process,
611: l_batch_size,

Line 628: ad_parallel_updates_pkg.processed_rowid_range(

624: );
625:
626: l_rows_processed := l_batch_size;
627:
628: ad_parallel_updates_pkg.processed_rowid_range(
629: l_rows_processed,
630: l_end_rowid);
631:
632: commit;

Line 637: ad_parallel_updates_pkg.get_rowid_range(

633:
634: --
635: -- get new range of rowids
636: --
637: ad_parallel_updates_pkg.get_rowid_range(
638: l_start_rowid,
639: l_end_rowid,
640: l_any_rows_to_process,
641: l_batch_size,

Line 657: ad_parallel_updates_pkg.initialize_rowid_range(

653: -- threaded
654: if (p_mode <> 'downtime') and (p_worker_id = 1) then
655:
656: -- for deferred table
657: ad_parallel_updates_pkg.initialize_rowid_range(
658: ad_parallel_updates_pkg.ROWID_RANGE,
659: p_table_owner,
660: l_table_name2,
661: p_script_name,

Line 658: ad_parallel_updates_pkg.ROWID_RANGE,

654: if (p_mode <> 'downtime') and (p_worker_id = 1) then
655:
656: -- for deferred table
657: ad_parallel_updates_pkg.initialize_rowid_range(
658: ad_parallel_updates_pkg.ROWID_RANGE,
659: p_table_owner,
660: l_table_name2,
661: p_script_name,
662: 1, -- p_worker_id

Line 666: ad_parallel_updates_pkg.get_rowid_range(

662: 1, -- p_worker_id
663: 1, -- p_workers_num
664: l_batch_size, 0);
665:
666: ad_parallel_updates_pkg.get_rowid_range(
667: l_start_rowid,
668: l_end_rowid,
669: l_any_rows_to_process,
670: l_batch_size,

Line 686: ad_parallel_updates_pkg.processed_rowid_range(

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

Line 695: ad_parallel_updates_pkg.get_rowid_range(

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