DBA Data[Home] [Help]

APPS.QP_BLK_LOAD_UPG_PKG dependencies on AD_PARALLEL_UPDATES_PKG

Line 156: ad_parallel_updates_pkg.initialize_rowid_range(

152: fnd_file.put_line(FND_FILE.LOG, 'X_Num_Workers : '||X_Num_Workers);
153:
154: BEGIN
155: --Initialize Header Update
156: ad_parallel_updates_pkg.initialize_rowid_range(
157: ad_parallel_updates_pkg.ROWID_RANGE,
158: l_table_owner_hdr,
159: l_table_name_hdr,
160: l_update_name_hdr,

Line 157: ad_parallel_updates_pkg.ROWID_RANGE,

153:
154: BEGIN
155: --Initialize Header Update
156: ad_parallel_updates_pkg.initialize_rowid_range(
157: ad_parallel_updates_pkg.ROWID_RANGE,
158: l_table_owner_hdr,
159: l_table_name_hdr,
160: l_update_name_hdr,
161: X_worker_id,

Line 164: ad_parallel_updates_pkg.get_rowid_range(

160: l_update_name_hdr,
161: X_worker_id,
162: X_num_workers,
163: X_batch_size, 0);
164: ad_parallel_updates_pkg.get_rowid_range(
165: l_start_rowid_hdr,
166: l_end_rowid_hdr,
167: l_any_rows_to_process_hdr,
168: X_batch_size,

Line 178: ad_parallel_updates_pkg.processed_rowid_range(

174: Set qplh1.orig_system_header_ref = 'INT'||to_char(qplh1.list_header_id)
175: where qplh1.orig_system_header_ref is null
176: and qplh1.rowid between l_start_rowid_hdr and l_end_rowid_hdr;
177: l_rows_processed_hdr := SQL%ROWCOUNT;
178: ad_parallel_updates_pkg.processed_rowid_range(
179: l_rows_processed_hdr,
180: l_end_rowid_hdr);
181: commit;
182: ad_parallel_updates_pkg.get_rowid_range(

Line 182: ad_parallel_updates_pkg.get_rowid_range(

178: ad_parallel_updates_pkg.processed_rowid_range(
179: l_rows_processed_hdr,
180: l_end_rowid_hdr);
181: commit;
182: ad_parallel_updates_pkg.get_rowid_range(
183: l_start_rowid_hdr,
184: l_end_rowid_hdr,
185: l_any_rows_to_process_hdr,
186: X_batch_size,

Line 194: ad_parallel_updates_pkg.initialize_rowid_range(

190:
191:
192:
193: --Initialize Line Update
194: ad_parallel_updates_pkg.initialize_rowid_range(
195: ad_parallel_updates_pkg.ROWID_RANGE,
196: l_table_owner_line,
197: l_table_name_line,
198: l_update_name_line,

Line 195: ad_parallel_updates_pkg.ROWID_RANGE,

191:
192:
193: --Initialize Line Update
194: ad_parallel_updates_pkg.initialize_rowid_range(
195: ad_parallel_updates_pkg.ROWID_RANGE,
196: l_table_owner_line,
197: l_table_name_line,
198: l_update_name_line,
199: X_worker_id,

Line 202: ad_parallel_updates_pkg.get_rowid_range(

198: l_update_name_line,
199: X_worker_id,
200: X_num_workers,
201: X_batch_size, 0);
202: ad_parallel_updates_pkg.get_rowid_range(
203: l_start_rowid_line,
204: l_end_rowid_line,
205: l_any_rows_to_process_line,
206: X_batch_size,

Line 241: ad_parallel_updates_pkg.processed_rowid_range(

237: and l.rowid between l_start_rowid_line and l_end_rowid_line;
238:
239: -- Bug 13395264 end.
240:
241: ad_parallel_updates_pkg.processed_rowid_range(
242: l_rows_processed_line,
243: l_end_rowid_line);
244: commit;
245: ad_parallel_updates_pkg.get_rowid_range(

Line 245: ad_parallel_updates_pkg.get_rowid_range(

241: ad_parallel_updates_pkg.processed_rowid_range(
242: l_rows_processed_line,
243: l_end_rowid_line);
244: commit;
245: ad_parallel_updates_pkg.get_rowid_range(
246: l_start_rowid_line,
247: l_end_rowid_line,
248: l_any_rows_to_process_line,
249: X_batch_size,

Line 257: ad_parallel_updates_pkg.initialize_rowid_range(

253:
254:
255:
256: --Initialize Pricing Attribute Update
257: ad_parallel_updates_pkg.initialize_rowid_range(
258: ad_parallel_updates_pkg.ROWID_RANGE,
259: l_table_owner_pa,
260: l_table_name_pa,
261: l_update_name_pa,

Line 258: ad_parallel_updates_pkg.ROWID_RANGE,

254:
255:
256: --Initialize Pricing Attribute Update
257: ad_parallel_updates_pkg.initialize_rowid_range(
258: ad_parallel_updates_pkg.ROWID_RANGE,
259: l_table_owner_pa,
260: l_table_name_pa,
261: l_update_name_pa,
262: X_worker_id,

Line 265: ad_parallel_updates_pkg.get_rowid_range(

261: l_update_name_pa,
262: X_worker_id,
263: X_num_workers,
264: X_batch_size, 0);
265: ad_parallel_updates_pkg.get_rowid_range(
266: l_start_rowid_pa,
267: l_end_rowid_pa,
268: l_any_rows_to_process_pa,
269: X_batch_size,

Line 321: ad_parallel_updates_pkg.processed_rowid_range(

317: and p.rowid between l_start_rowid_pa and l_end_rowid_pa;
318:
319: -- Bug 13395264 end.
320:
321: ad_parallel_updates_pkg.processed_rowid_range(
322: l_rows_processed_pa,
323: l_end_rowid_pa);
324: commit;
325: ad_parallel_updates_pkg.get_rowid_range(

Line 325: ad_parallel_updates_pkg.get_rowid_range(

321: ad_parallel_updates_pkg.processed_rowid_range(
322: l_rows_processed_pa,
323: l_end_rowid_pa);
324: commit;
325: ad_parallel_updates_pkg.get_rowid_range(
326: l_start_rowid_pa,
327: l_end_rowid_pa,
328: l_any_rows_to_process_pa,
329: X_batch_size,

Line 337: ad_parallel_updates_pkg.initialize_rowid_range(

333:
334:
335:
336: --Initialize Qualifier Update
337: ad_parallel_updates_pkg.initialize_rowid_range(
338: ad_parallel_updates_pkg.ROWID_RANGE,
339: l_table_owner_qual,
340: l_table_name_qual,
341: l_update_name_qual,

Line 338: ad_parallel_updates_pkg.ROWID_RANGE,

334:
335:
336: --Initialize Qualifier Update
337: ad_parallel_updates_pkg.initialize_rowid_range(
338: ad_parallel_updates_pkg.ROWID_RANGE,
339: l_table_owner_qual,
340: l_table_name_qual,
341: l_update_name_qual,
342: X_worker_id,

Line 345: ad_parallel_updates_pkg.get_rowid_range(

341: l_update_name_qual,
342: X_worker_id,
343: X_num_workers,
344: X_batch_size, 0);
345: ad_parallel_updates_pkg.get_rowid_range(
346: l_start_rowid_qual,
347: l_end_rowid_qual,
348: l_any_rows_to_process_qual,
349: X_batch_size,

Line 386: ad_parallel_updates_pkg.processed_rowid_range(

382: and q.rowid between l_start_rowid_qual and l_end_rowid_qual;
383:
384: -- bug 13395264 end
385:
386: ad_parallel_updates_pkg.processed_rowid_range(
387: l_rows_processed_qual,
388: l_end_rowid_qual);
389: commit;
390: ad_parallel_updates_pkg.get_rowid_range(

Line 390: ad_parallel_updates_pkg.get_rowid_range(

386: ad_parallel_updates_pkg.processed_rowid_range(
387: l_rows_processed_qual,
388: l_end_rowid_qual);
389: commit;
390: ad_parallel_updates_pkg.get_rowid_range(
391: l_start_rowid_qual,
392: l_end_rowid_qual,
393: l_any_rows_to_process_qual,
394: X_batch_size,