DBA Data[Home] [Help]

APPS.EDW_DERIVED_FACT_COLLECT dependencies on EDW_DERIVED_FACT_FACT_COLLECT

Line 100: if EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT(

96: return false;
97: end if;
98: l_pre_hook:='N';
99: l_post_hook:='N';
100: if EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT(
101: g_fact_name,
102: g_fact_id,
103: g_mapping_ids(g_number_mapping_ids),
104: g_src_objects(g_number_mapping_ids),

Line 144: write_to_log_file_n('EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT returned with error '||get_time);

140: p_src_join_nl_percentage,
141: l_pre_hook,
142: l_post_hook
143: ) = false then
144: write_to_log_file_n('EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT returned with error '||get_time);
145: g_status_message:=EDW_DERIVED_FACT_FACT_COLLECT.get_status_message;
146: return false;
147: end if;
148: return true;

Line 145: g_status_message:=EDW_DERIVED_FACT_FACT_COLLECT.get_status_message;

141: l_pre_hook,
142: l_post_hook
143: ) = false then
144: write_to_log_file_n('EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT returned with error '||get_time);
145: g_status_message:=EDW_DERIVED_FACT_FACT_COLLECT.get_status_message;
146: return false;
147: end if;
148: return true;
149: Exception when others then

Line 450: write_to_log_file_n('EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT_MULTI_THREAD('''||g_fact_name||''','||

446: if g_debug then
447: write_to_log_file_n('Launch conc process '||l_temp_conc_name||' '||i);
448: end if;
449: if g_debug then
450: write_to_log_file_n('EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT_MULTI_THREAD('''||g_fact_name||''','||
451: g_fact_id||','''||l_log_file||''','''||l_input_table(i)||''','''||l_ilog(i)||''','''||l_dlog(i)||''','''||
452: l_pre_hook||''','''||l_post_hook||''','''||g_thread_type||''');');
453: end if;
454: l_flag:=true;

Line 480: write_to_log_file_n('EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT_MULTI_THREAD('''||g_fact_name||''','||

476: end if;
477: commit;--commit very imp, starts the conc request
478: else --here g_thread_type='JOB'
479: if g_debug then
480: write_to_log_file_n('EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT_MULTI_THREAD('''||g_fact_name||''','||
481: g_fact_id||','''||l_log_file||''','''||l_input_table(i)||''','''||l_ilog(i)||''','''||l_dlog(i)||''','''||
482: l_pre_hook||''','''||l_post_hook||''','''||g_thread_type||''');');
483: end if;
484: DBMS_JOB.SUBMIT(l_job_id(i),'EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT_MULTI_THREAD('''||

Line 484: DBMS_JOB.SUBMIT(l_job_id(i),'EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT_MULTI_THREAD('''||

480: write_to_log_file_n('EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT_MULTI_THREAD('''||g_fact_name||''','||
481: g_fact_id||','''||l_log_file||''','''||l_input_table(i)||''','''||l_ilog(i)||''','''||l_dlog(i)||''','''||
482: l_pre_hook||''','''||l_post_hook||''','''||g_thread_type||''');');
483: end if;
484: DBMS_JOB.SUBMIT(l_job_id(i),'EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT_MULTI_THREAD('''||
485: g_fact_name||''','||g_fact_id||','''||l_log_file||''','''||l_input_table(i)||''','''||
486: l_ilog(i)||''','''||l_dlog(i)||''','''||l_pre_hook||''','''||l_post_hook||''','''||
487: g_thread_type||''');');
488: l_job_status(i):='R';

Line 520: EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT_MULTI_THREAD(

516: return false;
517: end if;
518: commit;
519: l_job_status(i):='R';
520: EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT_MULTI_THREAD(
521: l_errbuf,
522: l_retcode,
523: g_fact_name,
524: g_fact_id,

Line 662: l_bool_flag:=EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT(

658: --l_ilog(i):=g_bis_owner||'.I_'||p_src_fact_id||'_'||l_derived_fact_ids(i);
659: --l_dlog(i):=g_bis_owner||'.D_'||p_src_fact_id||'_'||l_derived_fact_ids(i);
660: l_ilog(i):=edw_owb_collection_util.get_fact_dfact_ilog(g_bis_owner,p_src_fact_id,l_derived_fact_ids(i));
661: l_dlog(i):=edw_owb_collection_util.get_fact_dfact_dlog(g_bis_owner,p_src_fact_id,l_derived_fact_ids(i));
662: l_bool_flag:=EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT(
663: g_fact_name,
664: g_fact_id,
665: g_mapping_ids(g_number_mapping_ids),
666: g_src_objects(g_number_mapping_ids),

Line 707: g_status_message:=EDW_DERIVED_FACT_FACT_COLLECT.get_status_message;

703: l_pre_hook,
704: l_post_hook
705: );
706: if l_bool_flag=false then
707: g_status_message:=EDW_DERIVED_FACT_FACT_COLLECT.get_status_message;
708: p_status(i):='ERROR';
709: p_message(i):=g_status_message;
710: else
711: p_status(i):='SUCCESS';

Line 993: write_to_log_file_n('EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT_MULTI_THREAD('''||g_fact_name||''','||

989: Launch the thread
990: */
991: l_number_jobs:=l_number_jobs+1;
992: if g_debug then
993: write_to_log_file_n('EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT_MULTI_THREAD('''||g_fact_name||''','||
994: g_fact_id||','''||l_log_file||''','''||l_input_table(i)||''','''||l_ilog(i)||''','''||l_dlog(i)||''','''||
995: l_pre_hook||''','''||l_post_hook||''','''||g_thread_type||''');');
996: end if;
997: begin

Line 1025: DBMS_JOB.SUBMIT(l_job_id(l_number_jobs),'EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT_MULTI_THREAD('''||

1021: l_try_serial:=true;
1022: end if;
1023: commit;--commit only after updating the inp table
1024: else
1025: DBMS_JOB.SUBMIT(l_job_id(l_number_jobs),'EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT_MULTI_THREAD('''||
1026: g_fact_name||''','||g_fact_id||','''||l_log_file||''','''||l_input_table(i)||''','''||
1027: l_ilog(i)||''','''||l_dlog(i)||''','''||l_pre_hook||''','''||l_post_hook||''','''||g_thread_type||
1028: ''');');
1029: l_job_status(l_number_jobs):='R';

Line 1058: EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT_MULTI_THREAD(

1054: if EDW_OWB_COLLECTION_UTIL.update_inp_table_jobid(l_input_table(i),l_job_id(l_number_jobs))=false then
1055: return false;
1056: end if;
1057: commit;--commit only after updating the inp table
1058: EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT_MULTI_THREAD(
1059: l_errbuf,
1060: l_retcode,
1061: g_fact_name,
1062: g_fact_id,

Line 1131: if EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT(

1127: if g_debug then
1128: write_to_log_file_n('Going to collect mapping: id='||g_mapping_ids(i)||', src='||g_src_objects(i));
1129: end if;
1130: -- the last true is for yes to full refresh
1131: if EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT(
1132: g_fact_name,
1133: g_fact_id,
1134: g_mapping_ids(i),
1135: g_src_objects(i),

Line 1174: write_to_log_file_n('EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT returned with error '||get_time);

1170: p_rollback,
1171: p_src_join_nl_percentage,
1172: l_pre_hook,
1173: l_post_hook) = false then
1174: write_to_log_file_n('EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT returned with error '||get_time);
1175: g_status_message:=EDW_DERIVED_FACT_FACT_COLLECT.get_status_message;
1176: return false;
1177: else
1178: g_ins_rows_processed:=g_ins_rows_processed+l_ins_rows_processed;

Line 1175: g_status_message:=EDW_DERIVED_FACT_FACT_COLLECT.get_status_message;

1171: p_src_join_nl_percentage,
1172: l_pre_hook,
1173: l_post_hook) = false then
1174: write_to_log_file_n('EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT returned with error '||get_time);
1175: g_status_message:=EDW_DERIVED_FACT_FACT_COLLECT.get_status_message;
1176: return false;
1177: else
1178: g_ins_rows_processed:=g_ins_rows_processed+l_ins_rows_processed;
1179: write_to_log_file_n('EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT returned with success '||get_time);

Line 1179: write_to_log_file_n('EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT returned with success '||get_time);

1175: g_status_message:=EDW_DERIVED_FACT_FACT_COLLECT.get_status_message;
1176: return false;
1177: else
1178: g_ins_rows_processed:=g_ins_rows_processed+l_ins_rows_processed;
1179: write_to_log_file_n('EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT returned with success '||get_time);
1180: end if;
1181: end loop;
1182: end if;
1183: p_ins_rows_processed:=g_ins_rows_processed;

Line 1204: write_to_log_file_n('EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT done. Total rows processed ='||g_ins_rows_processed);

1200: null;
1201: end if;
1202: end loop;
1203: if g_debug then
1204: write_to_log_file_n('EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT done. Total rows processed ='||g_ins_rows_processed);
1205: end if;
1206: return true;
1207: Exception when others then
1208: g_status_message:=sqlerrm;

Line 1828: 'EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT_MULTI_THREAD',

1824: if EDW_OWB_COLLECTION_UTIL.create_conc_program(
1825: p_temp_conc_name,
1826: p_temp_conc_short_name,
1827: p_temp_exe_name,
1828: 'EDW_DERIVED_FACT_FACT_COLLECT.COLLECT_FACT_MULTI_THREAD',
1829: p_bis_short_name,
1830: l_parameter,
1831: l_parameter_value_set,
1832: l_number_parameters