DBA Data[Home] [Help]

APPS.AR_UPG_PSA_DIST_PKG dependencies on AD_PARALLEL_UPDATES_PKG

Line 31: ad_parallel_updates_pkg.initialize_rowid_range(

27: l_nb_row NUMBER;
28: BEGIN
29:
30: /* ------ Initialize the rowid ranges ------ */
31: ad_parallel_updates_pkg.initialize_rowid_range(
32: ad_parallel_updates_pkg.ROWID_RANGE,
33: l_table_owner,
34: l_table_name,
35: l_script_name,

Line 32: ad_parallel_updates_pkg.ROWID_RANGE,

28: BEGIN
29:
30: /* ------ Initialize the rowid ranges ------ */
31: ad_parallel_updates_pkg.initialize_rowid_range(
32: ad_parallel_updates_pkg.ROWID_RANGE,
33: l_table_owner,
34: l_table_name,
35: l_script_name,
36: l_worker_id,

Line 41: ad_parallel_updates_pkg.get_rowid_range(

37: l_num_workers,
38: l_batch_size, 0);
39:
40: /* ------ Get rowid ranges ------ */
41: ad_parallel_updates_pkg.get_rowid_range(
42: l_start_rowid,
43: l_end_rowid,
44: l_any_rows_to_process,
45: l_batch_size,

Line 294: ad_parallel_updates_pkg.processed_rowid_range(

290: AND psatd.cust_trx_line_gl_dist_id = ctlgd.cust_trx_line_gl_dist_id
291: AND doub.customer_trx_id = trx.customer_trx_id;
292:
293:
294: ad_parallel_updates_pkg.processed_rowid_range(
295: l_rows_processed,
296: l_end_rowid);
297:
298: commit;

Line 300: ad_parallel_updates_pkg.get_rowid_range(

296: l_end_rowid);
297:
298: commit;
299:
300: ad_parallel_updates_pkg.get_rowid_range(
301: l_start_rowid,
302: l_end_rowid,
303: l_any_rows_to_process,
304: l_batch_size,

Line 342: ad_parallel_updates_pkg.initialize_rowid_range(

338: l_rows_processed number := 0;
339: BEGIN
340:
341: /* ------ Initialize the rowid ranges ------ */
342: ad_parallel_updates_pkg.initialize_rowid_range(
343: ad_parallel_updates_pkg.ROWID_RANGE,
344: l_table_owner,
345: l_table_name,
346: l_script_name,

Line 343: ad_parallel_updates_pkg.ROWID_RANGE,

339: BEGIN
340:
341: /* ------ Initialize the rowid ranges ------ */
342: ad_parallel_updates_pkg.initialize_rowid_range(
343: ad_parallel_updates_pkg.ROWID_RANGE,
344: l_table_owner,
345: l_table_name,
346: l_script_name,
347: l_worker_id,

Line 352: ad_parallel_updates_pkg.get_rowid_range(

348: l_num_workers,
349: l_batch_size, 0);
350:
351: /* ------ Get rowid ranges ------ */
352: ad_parallel_updates_pkg.get_rowid_range(
353: l_start_rowid,
354: l_end_rowid,
355: l_any_rows_to_process,
356: l_batch_size,

Line 974: ad_parallel_updates_pkg.processed_rowid_range(

970: AND EXISTS (SELECT NULL FROM psa_mf_rct_dist_all psa
971: WHERE psa.receivable_application_id = app.receivable_application_id);
972:
973:
974: ad_parallel_updates_pkg.processed_rowid_range(
975: l_rows_processed,
976: l_end_rowid);
977:
978: commit;

Line 980: ad_parallel_updates_pkg.get_rowid_range(

976: l_end_rowid);
977:
978: commit;
979:
980: ad_parallel_updates_pkg.get_rowid_range(
981: l_start_rowid,
982: l_end_rowid,
983: l_any_rows_to_process,
984: l_batch_size,

Line 1019: ad_parallel_updates_pkg.initialize_rowid_range(

1015: l_rows_processed number := 0;
1016: BEGIN
1017:
1018: /* ------ Initialize the rowid ranges ------ */
1019: ad_parallel_updates_pkg.initialize_rowid_range(
1020: ad_parallel_updates_pkg.ROWID_RANGE,
1021: l_table_owner,
1022: l_table_name,
1023: l_script_name,

Line 1020: ad_parallel_updates_pkg.ROWID_RANGE,

1016: BEGIN
1017:
1018: /* ------ Initialize the rowid ranges ------ */
1019: ad_parallel_updates_pkg.initialize_rowid_range(
1020: ad_parallel_updates_pkg.ROWID_RANGE,
1021: l_table_owner,
1022: l_table_name,
1023: l_script_name,
1024: l_worker_id,

Line 1029: ad_parallel_updates_pkg.get_rowid_range(

1025: l_num_workers,
1026: l_batch_size, 0);
1027:
1028: /* ------ Get rowid ranges ------ */
1029: ad_parallel_updates_pkg.get_rowid_range(
1030: l_start_rowid,
1031: l_end_rowid,
1032: l_any_rows_to_process,
1033: l_batch_size,

Line 1205: ad_parallel_updates_pkg.processed_rowid_range(

1201:
1202:
1203: l_rows_processed := l_rows_processed + SQL%ROWCOUNT;
1204:
1205: ad_parallel_updates_pkg.processed_rowid_range(
1206: l_rows_processed,
1207: l_end_rowid);
1208:
1209: commit;

Line 1211: ad_parallel_updates_pkg.get_rowid_range(

1207: l_end_rowid);
1208:
1209: commit;
1210:
1211: ad_parallel_updates_pkg.get_rowid_range(
1212: l_start_rowid,
1213: l_end_rowid,
1214: l_any_rows_to_process,
1215: l_batch_size,

Line 1669: ad_parallel_updates_pkg.initialize_rowid_range(

1665: l_last_fetch BOOLEAN := FALSE;
1666: BEGIN
1667:
1668: /* ------ Initialize the rowid ranges ------ */
1669: ad_parallel_updates_pkg.initialize_rowid_range(
1670: ad_parallel_updates_pkg.ROWID_RANGE,
1671: l_table_owner,
1672: l_table_name,
1673: l_script_name,

Line 1670: ad_parallel_updates_pkg.ROWID_RANGE,

1666: BEGIN
1667:
1668: /* ------ Initialize the rowid ranges ------ */
1669: ad_parallel_updates_pkg.initialize_rowid_range(
1670: ad_parallel_updates_pkg.ROWID_RANGE,
1671: l_table_owner,
1672: l_table_name,
1673: l_script_name,
1674: l_worker_id,

Line 1679: ad_parallel_updates_pkg.get_rowid_range(

1675: l_num_workers,
1676: l_batch_size, 0);
1677:
1678: /* ------ Get rowid ranges ------ */
1679: ad_parallel_updates_pkg.get_rowid_range(
1680: l_start_rowid,
1681: l_end_rowid,
1682: l_any_rows_to_process,
1683: l_batch_size,

Line 2153: ad_parallel_updates_pkg.processed_rowid_range(

2149: CLOSE c;
2150:
2151: l_rows_processed := l_rows_processed + SQL%ROWCOUNT;
2152:
2153: ad_parallel_updates_pkg.processed_rowid_range(
2154: l_rows_processed,
2155: l_end_rowid);
2156:
2157: commit;

Line 2159: ad_parallel_updates_pkg.get_rowid_range(

2155: l_end_rowid);
2156:
2157: commit;
2158:
2159: ad_parallel_updates_pkg.get_rowid_range(
2160: l_start_rowid,
2161: l_end_rowid,
2162: l_any_rows_to_process,
2163: l_batch_size,