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 222: ad_parallel_updates_pkg.processed_rowid_range(

218: )
219: where l.orig_sys_line_ref is null
220: and l.rowid between l_start_rowid_line and l_end_rowid_line;
221: l_rows_processed_line := SQL%ROWCOUNT;
222: ad_parallel_updates_pkg.processed_rowid_range(
223: l_rows_processed_line,
224: l_end_rowid_line);
225: commit;
226: ad_parallel_updates_pkg.get_rowid_range(

Line 226: ad_parallel_updates_pkg.get_rowid_range(

222: ad_parallel_updates_pkg.processed_rowid_range(
223: l_rows_processed_line,
224: l_end_rowid_line);
225: commit;
226: ad_parallel_updates_pkg.get_rowid_range(
227: l_start_rowid_line,
228: l_end_rowid_line,
229: l_any_rows_to_process_line,
230: X_batch_size,

Line 238: ad_parallel_updates_pkg.initialize_rowid_range(

234:
235:
236:
237: --Initialize Pricing Attribute Update
238: ad_parallel_updates_pkg.initialize_rowid_range(
239: ad_parallel_updates_pkg.ROWID_RANGE,
240: l_table_owner_pa,
241: l_table_name_pa,
242: l_update_name_pa,

Line 239: ad_parallel_updates_pkg.ROWID_RANGE,

235:
236:
237: --Initialize Pricing Attribute Update
238: ad_parallel_updates_pkg.initialize_rowid_range(
239: ad_parallel_updates_pkg.ROWID_RANGE,
240: l_table_owner_pa,
241: l_table_name_pa,
242: l_update_name_pa,
243: X_worker_id,

Line 246: ad_parallel_updates_pkg.get_rowid_range(

242: l_update_name_pa,
243: X_worker_id,
244: X_num_workers,
245: X_batch_size, 0);
246: ad_parallel_updates_pkg.get_rowid_range(
247: l_start_rowid_pa,
248: l_end_rowid_pa,
249: l_any_rows_to_process_pa,
250: X_batch_size,

Line 272: ad_parallel_updates_pkg.processed_rowid_range(

268: )
269: where p.ORIG_SYS_PRICING_ATTR_REF is null
270: and p.rowid between l_start_rowid_pa and l_end_rowid_pa;
271: l_rows_processed_pa := SQL%ROWCOUNT;
272: ad_parallel_updates_pkg.processed_rowid_range(
273: l_rows_processed_pa,
274: l_end_rowid_pa);
275: commit;
276: ad_parallel_updates_pkg.get_rowid_range(

Line 276: ad_parallel_updates_pkg.get_rowid_range(

272: ad_parallel_updates_pkg.processed_rowid_range(
273: l_rows_processed_pa,
274: l_end_rowid_pa);
275: commit;
276: ad_parallel_updates_pkg.get_rowid_range(
277: l_start_rowid_pa,
278: l_end_rowid_pa,
279: l_any_rows_to_process_pa,
280: X_batch_size,

Line 288: ad_parallel_updates_pkg.initialize_rowid_range(

284:
285:
286:
287: --Initialize Qualifier Update
288: ad_parallel_updates_pkg.initialize_rowid_range(
289: ad_parallel_updates_pkg.ROWID_RANGE,
290: l_table_owner_qual,
291: l_table_name_qual,
292: l_update_name_qual,

Line 289: ad_parallel_updates_pkg.ROWID_RANGE,

285:
286:
287: --Initialize Qualifier Update
288: ad_parallel_updates_pkg.initialize_rowid_range(
289: ad_parallel_updates_pkg.ROWID_RANGE,
290: l_table_owner_qual,
291: l_table_name_qual,
292: l_update_name_qual,
293: X_worker_id,

Line 296: ad_parallel_updates_pkg.get_rowid_range(

292: l_update_name_qual,
293: X_worker_id,
294: X_num_workers,
295: X_batch_size, 0);
296: ad_parallel_updates_pkg.get_rowid_range(
297: l_start_rowid_qual,
298: l_end_rowid_qual,
299: l_any_rows_to_process_qual,
300: X_batch_size,

Line 317: ad_parallel_updates_pkg.processed_rowid_range(

313: where q.orig_sys_qualifier_ref is null
314: and q.list_header_id is not null
315: and q.rowid between l_start_rowid_qual and l_end_rowid_qual;
316: l_rows_processed_qual := SQL%ROWCOUNT;
317: ad_parallel_updates_pkg.processed_rowid_range(
318: l_rows_processed_qual,
319: l_end_rowid_qual);
320: commit;
321: ad_parallel_updates_pkg.get_rowid_range(

Line 321: ad_parallel_updates_pkg.get_rowid_range(

317: ad_parallel_updates_pkg.processed_rowid_range(
318: l_rows_processed_qual,
319: l_end_rowid_qual);
320: commit;
321: ad_parallel_updates_pkg.get_rowid_range(
322: l_start_rowid_qual,
323: l_end_rowid_qual,
324: l_any_rows_to_process_qual,
325: X_batch_size,