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 1023: ad_parallel_updates_pkg.initialize_rowid_range(

1019: l_rows_processed number := 0;
1020: BEGIN
1021:
1022: /* ------ Initialize the rowid ranges ------ */
1023: ad_parallel_updates_pkg.initialize_rowid_range(
1024: ad_parallel_updates_pkg.ROWID_RANGE,
1025: l_table_owner,
1026: l_table_name,
1027: l_script_name,

Line 1024: ad_parallel_updates_pkg.ROWID_RANGE,

1020: BEGIN
1021:
1022: /* ------ Initialize the rowid ranges ------ */
1023: ad_parallel_updates_pkg.initialize_rowid_range(
1024: ad_parallel_updates_pkg.ROWID_RANGE,
1025: l_table_owner,
1026: l_table_name,
1027: l_script_name,
1028: l_worker_id,

Line 1033: ad_parallel_updates_pkg.get_rowid_range(

1029: l_num_workers,
1030: l_batch_size, 0);
1031:
1032: /* ------ Get rowid ranges ------ */
1033: ad_parallel_updates_pkg.get_rowid_range(
1034: l_start_rowid,
1035: l_end_rowid,
1036: l_any_rows_to_process,
1037: l_batch_size,

Line 1171: ad_parallel_updates_pkg.processed_rowid_range(

1167:
1168:
1169: l_rows_processed := l_rows_processed + SQL%ROWCOUNT;
1170:
1171: ad_parallel_updates_pkg.processed_rowid_range(
1172: l_rows_processed,
1173: l_end_rowid);
1174:
1175: commit;

Line 1177: ad_parallel_updates_pkg.get_rowid_range(

1173: l_end_rowid);
1174:
1175: commit;
1176:
1177: ad_parallel_updates_pkg.get_rowid_range(
1178: l_start_rowid,
1179: l_end_rowid,
1180: l_any_rows_to_process,
1181: l_batch_size,

Line 1590: ad_parallel_updates_pkg.initialize_rowid_range(

1586: l_last_fetch BOOLEAN := FALSE;
1587: BEGIN
1588:
1589: /* ------ Initialize the rowid ranges ------ */
1590: ad_parallel_updates_pkg.initialize_rowid_range(
1591: ad_parallel_updates_pkg.ROWID_RANGE,
1592: l_table_owner,
1593: l_table_name,
1594: l_script_name,

Line 1591: ad_parallel_updates_pkg.ROWID_RANGE,

1587: BEGIN
1588:
1589: /* ------ Initialize the rowid ranges ------ */
1590: ad_parallel_updates_pkg.initialize_rowid_range(
1591: ad_parallel_updates_pkg.ROWID_RANGE,
1592: l_table_owner,
1593: l_table_name,
1594: l_script_name,
1595: l_worker_id,

Line 1600: ad_parallel_updates_pkg.get_rowid_range(

1596: l_num_workers,
1597: l_batch_size, 0);
1598:
1599: /* ------ Get rowid ranges ------ */
1600: ad_parallel_updates_pkg.get_rowid_range(
1601: l_start_rowid,
1602: l_end_rowid,
1603: l_any_rows_to_process,
1604: l_batch_size,

Line 1959: ad_parallel_updates_pkg.processed_rowid_range(

1955: CLOSE c;
1956:
1957: l_rows_processed := l_rows_processed + SQL%ROWCOUNT;
1958:
1959: ad_parallel_updates_pkg.processed_rowid_range(
1960: l_rows_processed,
1961: l_end_rowid);
1962:
1963: commit;

Line 1965: ad_parallel_updates_pkg.get_rowid_range(

1961: l_end_rowid);
1962:
1963: commit;
1964:
1965: ad_parallel_updates_pkg.get_rowid_range(
1966: l_start_rowid,
1967: l_end_rowid,
1968: l_any_rows_to_process,
1969: l_batch_size,