/*==========================================================================*
 * Step:            Extract                               A538FOH5.BY00007B *
 * Transform:       Extract                                                 *
 * Description:                                                             *
 *                                                                          *
 * Source Table:    CAR_HOURLY_INT -                      A538FOH5.BG0000C1 *
 *                   HDPHUB.CAR_HOURLY_INT                                  *
 * Target Table:    Extract - work.WAJ3UO6                A538FOH5.BW00002T *
 *==========================================================================*/

%let transformID = %quote(A538FOH5.BY00007B);
%let trans_rc = 0;
%let etls_stepStartTime = %sysfunc(datetime(), datetime20.);

/* Access the data for HDPHUB  */
LIBNAME HDPHUB HADOOP  uri="jdbc:hive2://hive-sqa1.uscc.com:10000/pre_hub;principal=hive/_HOST@INT.USC.LOCAL"  hdfs_tempdir="/sastmp"  PORT=10000 SERVER="hive-sqa1.uscc.com"  SCHEMA=pre_hub ;
%rcSet(&syslibrc);

%let etls_recnt = 0;
%macro etls_recordCheck;
   %let etls_recCheckExist = %eval(%sysfunc(exist(HDPHUB.CAR_HOURLY_INT, DATA)) or
         %sysfunc(exist(HDPHUB.CAR_HOURLY_INT, VIEW)));

   %if (&etls_recCheckExist) %then
   %do;
      proc sql noprint;
         select count(*) into :etls_recnt from HDPHUB.CAR_HOURLY_INT;
      quit;
   %end;
%mend etls_recordCheck;
%etls_recordCheck;

%let SYSLAST = %nrquote(HDPHUB.CAR_HOURLY_INT);

/* Runtime statistics macros  */
%etls_setPerfInit;
%perfstrt(txnname=%BQUOTE(_DISARM|&transformID|&syshostname|Extract), metrNam6=_DISROWCNT, metrDef6=Count32)   ;

%global etls_sql_pushDown;
%let etls_sql_pushDown = -1;
option DBIDIRECTEXEC;

/*---- Map the columns  ----*/
proc datasets lib = work nolist nowarn memtype = (data view);
   delete WAJ3UO6;
quit;

%put %str(NOTE: Mapping columns ...);
proc sql;
   create table work.WAJ3UO6 as
      select
         sscr_mstr_id,
         ctrct_cmtm_svc_timer_end_dt,
         ctrct_cmtm_svc_timer_strt_dt,
         ctrct_eip_typ_desc,
         ctrct_equip_typ_cd,
         ctrct_stat_desc,
         ctrct_subsidy_timer_end_dt,
         ctrct_subsidy_timer_strt_dt,
         ctrct_term_num,
         equip_cat_desc,
         equip_data_cpbl_ind,
         equip_gps_cpbl_ind,
         equip_gsm_intl_roam_cpbl_ind,
         equip_inv_pool_desc,
         equip_itm_clr_nm,
         equip_lng_desc,
         equip_lte_cpbl_ind,
         equip_mfr_nm,
         equip_model_desc,
         equip_net_tech_desc,
         equip_os_desc,
         equip_shrt_desc,
         equip_sku_id,
         equip_sub_cat_desc,
         equip_volte_cpbl_ind,
         sscr_init_act_chnl_lvl_1_desc,
         sscr_init_act_chnl_lvl_2_desc,
         sscr_init_act_chnl_lvl_3_desc,
         sscr_init_act_fac_city_nm,
         sscr_init_act_fac_desc,
         sscr_init_act_fac_state_nm,
         sscr_init_act_fac_submkt_cd,
         sscr_init_act_fac_submkt_nm,
         sscr_init_act_fac_typ_desc,
         sscr_init_act_fac_zip_cd,
         sscr_init_actvn_fac_busn_cd,
         sscr_init_actvn_fac_busn_nm,
         sscr_init_actvn_mrkt_nm,
         sscr_init_actvn_regn_nm,
         sscr_init_actvn_terr_nm,
         sys_insr_dt,
         partition_key,
         ods_insert_dt,
         (dhms(
            datepart(input(substr(put(import_date,10.),1,8),B8601DN8.))
            ,input(substr(put(import_date,10.),9,2),2.),
            0,0)) as import_date length = 8
            format = datetime18.
            informat = datetime18.
            label = 'import_date',
         insr_run_id
   from &SYSLAST
      where import_date > &DI_last_exec_datehh.
         and import_date<=&DI_current_exec_datehh.
   ;
quit;

%let SYSLAST = work.WAJ3UO6;

%global etls_sql_pushDown;
%let etls_sql_pushDown = &sys_sql_ip_all;

%rcSet(&sqlrc);

%perfstop(metrVal6=%sysfunc(max(&etls_recnt,-1)));
%let etls_recnt=-1;



/** Step end Extract **/