16914: 'Cannot get schema name for product : '||l_product);
16915: END IF;
16916: FND_FILE.PUT_LINE(FND_FILE.LOG, ' x_worker_id : '||x_worker_id);
16917: FND_FILE.PUT_LINE(FND_FILE.LOG, 'x_num_workers : '||x_num_workers);
16918: ad_parallel_updates_pkg.initialize_rowid_range(
16919: ad_parallel_updates_pkg.ROWID_RANGE
16920: ,l_table_owner
16921: ,l_table_name
16922: ,l_update_name
16915: END IF;
16916: FND_FILE.PUT_LINE(FND_FILE.LOG, ' x_worker_id : '||x_worker_id);
16917: FND_FILE.PUT_LINE(FND_FILE.LOG, 'x_num_workers : '||x_num_workers);
16918: ad_parallel_updates_pkg.initialize_rowid_range(
16919: ad_parallel_updates_pkg.ROWID_RANGE
16920: ,l_table_owner
16921: ,l_table_name
16922: ,l_update_name
16923: ,x_worker_id
16923: ,x_worker_id
16924: ,x_num_workers
16925: ,x_batch_size,0);
16926:
16927: ad_parallel_updates_pkg.get_rowid_range(
16928: l_start_rowid
16929: ,l_end_rowid
16930: ,l_any_rows_to_process
16931: ,x_batch_size
16944: AND rowid between l_start_rowid and l_end_rowid;
16945:
16946: l_rows_processed := SQL%ROWCOUNT;
16947:
16948: ad_parallel_updates_pkg.processed_rowid_range(
16949: l_rows_processed,
16950: l_end_rowid);
16951:
16952: commit;
16950: l_end_rowid);
16951:
16952: commit;
16953:
16954: ad_parallel_updates_pkg.get_rowid_range(
16955: l_start_rowid,
16956: l_end_rowid,
16957: l_any_rows_to_process,
16958: x_batch_size,