54:
55: BEGIN
56:
57: /* ------ Initialize the rowid ranges ------ */
58: ad_parallel_updates_pkg.initialize_rowid_range(
59: ad_parallel_updates_pkg.ROWID_RANGE,
60: l_table_owner,
61: l_table_name,
62: l_script_name,
55: BEGIN
56:
57: /* ------ Initialize the rowid ranges ------ */
58: ad_parallel_updates_pkg.initialize_rowid_range(
59: ad_parallel_updates_pkg.ROWID_RANGE,
60: l_table_owner,
61: l_table_name,
62: l_script_name,
63: l_worker_id,
64: l_num_workers,
65: l_batch_size, 0);
66:
67: /* ------ Get rowid ranges ------ */
68: ad_parallel_updates_pkg.get_rowid_range(
69: l_start_rowid,
70: l_end_rowid,
71: l_any_rows_to_process,
72: l_batch_size,
874: l_batch_id);
875:
876: END IF; --NVL(l_entity_type,'L') = 'L'
877:
878: ad_parallel_updates_pkg.processed_rowid_range(
879: l_rows_processed,
880: l_end_rowid);
881:
882: commit;
880: l_end_rowid);
881:
882: commit;
883:
884: ad_parallel_updates_pkg.get_rowid_range(
885: l_start_rowid,
886: l_end_rowid,
887: l_any_rows_to_process,
888: l_batch_size,
948:
949: BEGIN
950:
951: /* ------ Initialize the rowid ranges ------ */
952: ad_parallel_updates_pkg.initialize_rowid_range(
953: ad_parallel_updates_pkg.ROWID_RANGE,
954: l_table_owner,
955: l_table_name,
956: l_script_name,
949: BEGIN
950:
951: /* ------ Initialize the rowid ranges ------ */
952: ad_parallel_updates_pkg.initialize_rowid_range(
953: ad_parallel_updates_pkg.ROWID_RANGE,
954: l_table_owner,
955: l_table_name,
956: l_script_name,
957: l_worker_id,
958: l_num_workers,
959: l_batch_size, 0);
960:
961: /* ------ Get rowid ranges ------ */
962: ad_parallel_updates_pkg.get_rowid_range(
963: l_start_rowid,
964: l_end_rowid,
965: l_any_rows_to_process,
966: l_batch_size,
1742: l_batch_id);
1743:
1744: END IF; --NVL(l_entity_type,'L') = 'L'
1745:
1746: ad_parallel_updates_pkg.processed_rowid_range(
1747: l_rows_processed,
1748: l_end_rowid);
1749:
1750: commit;
1748: l_end_rowid);
1749:
1750: commit;
1751:
1752: ad_parallel_updates_pkg.get_rowid_range(
1753: l_start_rowid,
1754: l_end_rowid,
1755: l_any_rows_to_process,
1756: l_batch_size,
1815:
1816: BEGIN
1817:
1818: /* ------ Initialize the rowid ranges ------ */
1819: ad_parallel_updates_pkg.initialize_rowid_range(
1820: ad_parallel_updates_pkg.ROWID_RANGE,
1821: l_table_owner,
1822: l_table_name,
1823: l_script_name,
1816: BEGIN
1817:
1818: /* ------ Initialize the rowid ranges ------ */
1819: ad_parallel_updates_pkg.initialize_rowid_range(
1820: ad_parallel_updates_pkg.ROWID_RANGE,
1821: l_table_owner,
1822: l_table_name,
1823: l_script_name,
1824: l_worker_id,
1825: l_num_workers,
1826: l_batch_size, 0);
1827:
1828: /* ------ Get rowid ranges ------ */
1829: ad_parallel_updates_pkg.get_rowid_range(
1830: l_start_rowid,
1831: l_end_rowid,
1832: l_any_rows_to_process,
1833: l_batch_size,
2278: l_rows_processed := l_rows_processed + SQL%ROWCOUNT;
2279:
2280: END IF; --NVL(l_entity_type,'L') = 'L'
2281:
2282: ad_parallel_updates_pkg.processed_rowid_range(
2283: l_rows_processed,
2284: l_end_rowid);
2285:
2286: commit;
2284: l_end_rowid);
2285:
2286: commit;
2287:
2288: ad_parallel_updates_pkg.get_rowid_range(
2289: l_start_rowid,
2290: l_end_rowid,
2291: l_any_rows_to_process,
2292: l_batch_size,