[Home] [Help]
508: (PJI_RM_SUM_MAIN.g_process, 'EXTRACTION_TYPE');
509:
510: if (l_extraction_type = 'FULL') then
511:
512: insert /*+ append */ into PJI_RM_REXT_FCSTITEM
513: (
514: WORKER_ID
515: , FID_ROWID
516: , START_DATE
531: fid.PJI_SUMMARIZED_FLAG = 'N';
532:
533: else
534:
535: INSERT /*+ APPEND */ INTO PJI_RM_REXT_FCSTITEM
536: (
537: WORKER_ID
538: , FID_ROWID
539: , START_DATE
554: , ceil(ROWNUM / PJI_RM_SUM_MAIN.g_commit_threshold)
555: FROM
556: pji_rm_org_batch_map bat
557: , pa_forecast_item_details fid
558: , pji_rm_rext_fcstitem fcst
559: WHERE
560: bat.WORKER_ID = p_worker_id and
561: fid.EXPENDITURE_ORGANIZATION_ID = bat.ORGANIZATION_ID and
562: ((nvl(fid.PJI_SUMMARIZED_FLAG, 'N') <> 'X' and
617: PJI_RM_SUM_MAIN.g_date_mask), 'J'));
618:
619: -- implicit commit
620: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
621: tabname => 'PJI_RM_REXT_FCSTITEM',
622: percent => 10,
623: degree => BIS_COMMON_PARAMETERS.
624: GET_DEGREE_OF_PARALLELISM);
625:
768: nvl(nvl(fid.JOB_ID, res.JOB_ID), -1) JOB_ID,
769: fid.WORK_TYPE_ID,
770: fid.PROJECT_ID
771: from
772: PJI_RM_REXT_FCSTITEM scope,
773: PA_FORECAST_ITEM_DETAILS fid,
774: PA_FORECAST_ITEMS fi,
775: PJI_RM_WORK_TYPE_INFO wt,
776: PJI_RESOURCES_DENORM res,
1493: BATCH_ID,
1494: null,
1495: null
1496: from
1497: PJI_RM_REXT_FCSTITEM
1498: where
1499: PJI_SUMMARIZED_FLAG is not null;
1500:
1501: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION (l_process,
1570: (
1571: select /*+ cardinality(fcst, 1) */
1572: fcst.FID_ROWID
1573: from
1574: PJI_RM_REXT_FCSTITEM fcst
1575: where
1576: fcst.PJI_SUMMARIZED_FLAG = 'N' and
1577: fcst.BATCH_ID = l_helper_batch_id
1578: );
1676: PJI_FM_PLAN_EXTR.CLEANUP(p_worker_id);
1677: PJI_RM_SUM_ROLLUP_RES.CLEANUP(p_worker_id);
1678:
1679: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
1680: 'PJI_RM_REXT_FCSTITEM',
1681: 'NORMAL',
1682: null);
1683:
1684: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,