16903: 'Cannot get schema name for product : '||l_product);
16904: END IF;
16905: FND_FILE.PUT_LINE(FND_FILE.LOG, ' x_worker_id : '||x_worker_id);
16906: FND_FILE.PUT_LINE(FND_FILE.LOG, 'x_num_workers : '||x_num_workers);
16907: ad_parallel_updates_pkg.initialize_rowid_range(
16908: ad_parallel_updates_pkg.ROWID_RANGE
16909: ,l_table_owner
16910: ,l_table_name
16911: ,l_update_name
16904: END IF;
16905: FND_FILE.PUT_LINE(FND_FILE.LOG, ' x_worker_id : '||x_worker_id);
16906: FND_FILE.PUT_LINE(FND_FILE.LOG, 'x_num_workers : '||x_num_workers);
16907: ad_parallel_updates_pkg.initialize_rowid_range(
16908: ad_parallel_updates_pkg.ROWID_RANGE
16909: ,l_table_owner
16910: ,l_table_name
16911: ,l_update_name
16912: ,x_worker_id
16912: ,x_worker_id
16913: ,x_num_workers
16914: ,x_batch_size,0);
16915:
16916: ad_parallel_updates_pkg.get_rowid_range(
16917: l_start_rowid
16918: ,l_end_rowid
16919: ,l_any_rows_to_process
16920: ,x_batch_size
16933: AND rowid between l_start_rowid and l_end_rowid;
16934:
16935: l_rows_processed := SQL%ROWCOUNT;
16936:
16937: ad_parallel_updates_pkg.processed_rowid_range(
16938: l_rows_processed,
16939: l_end_rowid);
16940:
16941: commit;
16939: l_end_rowid);
16940:
16941: commit;
16942:
16943: ad_parallel_updates_pkg.get_rowid_range(
16944: l_start_rowid,
16945: l_end_rowid,
16946: l_any_rows_to_process,
16947: x_batch_size,