2439: --
2440: -- Worker processing
2441: --
2442: BEGIN
2443: ad_parallel_updates_pkg.initialize_rowid_range(ad_parallel_updates_pkg.ROWID_RANGE,
2444: l_table_owner,
2445: l_table_name,
2446: l_update_name,
2447: P_worker_id,
2447: P_worker_id,
2448: P_num_workers,
2449: P_batch_size,
2450: 0);
2451: ad_parallel_updates_pkg.get_rowid_range( l_start_rowid,
2452: l_end_rowid,
2453: l_any_rows_to_process,
2454: P_batch_size,
2455: TRUE);
2512: ,TAX_CODE = NULL;
2513: --end npalepu
2514:
2515: l_rows_processed := SQL%ROWCOUNT;
2516: ad_parallel_updates_pkg.processed_rowid_range(l_rows_processed,
2517: l_end_rowid);
2518: commit;
2519: ad_parallel_updates_pkg.get_rowid_range(l_start_rowid,
2520: l_end_rowid,
2515: l_rows_processed := SQL%ROWCOUNT;
2516: ad_parallel_updates_pkg.processed_rowid_range(l_rows_processed,
2517: l_end_rowid);
2518: commit;
2519: ad_parallel_updates_pkg.get_rowid_range(l_start_rowid,
2520: l_end_rowid,
2521: l_any_rows_to_process,
2522: P_batch_size,
2523: FALSE);
2580: --
2581: -- Worker processing
2582: --
2583: BEGIN
2584: ad_parallel_updates_pkg.initialize_rowid_range(ad_parallel_updates_pkg.ROWID_RANGE,
2585: l_table_owner,
2586: l_table_name,
2587: l_update_name,
2588: P_worker_id,
2588: P_worker_id,
2589: P_num_workers,
2590: P_batch_size,
2591: 0);
2592: ad_parallel_updates_pkg.get_rowid_range( l_start_rowid,
2593: l_end_rowid,
2594: l_any_rows_to_process,
2595: P_batch_size,
2596: TRUE);
2652: ,TAX_CODE = NULL;
2653: --end npalepu
2654:
2655: l_rows_processed := SQL%ROWCOUNT;
2656: ad_parallel_updates_pkg.processed_rowid_range(l_rows_processed,
2657: l_end_rowid);
2658: commit;
2659: ad_parallel_updates_pkg.get_rowid_range(l_start_rowid,
2660: l_end_rowid,
2655: l_rows_processed := SQL%ROWCOUNT;
2656: ad_parallel_updates_pkg.processed_rowid_range(l_rows_processed,
2657: l_end_rowid);
2658: commit;
2659: ad_parallel_updates_pkg.get_rowid_range(l_start_rowid,
2660: l_end_rowid,
2661: l_any_rows_to_process,
2662: P_batch_size,
2663: FALSE);