DBA Data[Home] [Help]

APPS.CS_CONTPNTS_AUDIT_UPD_CON_PRG dependencies on AD_PARALLEL_UPDATES_PKG

Line 79: ad_parallel_updates_pkg.initialize_rowid_range(

75: l_cutoff_date := to_date(p_cutoff_date, 'YYYY/MM/DD HH24:MI:SS');
76:
77: FND_FILE.Put_Line(fnd_file.log, 'p_cutoff_date=' || p_cutoff_date);
78:
79: ad_parallel_updates_pkg.initialize_rowid_range(
80: ad_parallel_updates_pkg.ROWID_RANGE,
81: l_table_owner,
82: l_table_name,
83: l_update_name || p_update_date, -- to ensure it is rerunnable

Line 80: ad_parallel_updates_pkg.ROWID_RANGE,

76:
77: FND_FILE.Put_Line(fnd_file.log, 'p_cutoff_date=' || p_cutoff_date);
78:
79: ad_parallel_updates_pkg.initialize_rowid_range(
80: ad_parallel_updates_pkg.ROWID_RANGE,
81: l_table_owner,
82: l_table_name,
83: l_update_name || p_update_date, -- to ensure it is rerunnable
84: x_worker_id,

Line 88: ad_parallel_updates_pkg.get_rowid_range(

84: x_worker_id,
85: x_num_workers,
86: x_batch_size, 0);
87:
88: ad_parallel_updates_pkg.get_rowid_range(
89: l_start_rowid,
90: l_end_rowid,
91: l_any_rows_to_process,
92: x_batch_size,

Line 163: ad_parallel_updates_pkg.processed_rowid_range(

159: WHERE a.sr_contact_point_id = cp.sr_contact_point_id);
160:
161: l_rows_processed := SQL%ROWCOUNT;
162:
163: ad_parallel_updates_pkg.processed_rowid_range(
164: l_rows_processed,
165: l_end_rowid);
166:
167: --

Line 175: ad_parallel_updates_pkg.get_rowid_range(

171: --
172:
173: -- get new range of rowids
174: --
175: ad_parallel_updates_pkg.get_rowid_range(
176: l_start_rowid,
177: l_end_rowid,
178: l_any_rows_to_process,
179: x_batch_size,