CREATE TABLE ped_stg_usa.us_kol_engagement (  
 activity_name_eng varchar(256),
 activity_type_eng varchar(256),
 partnering_department_eng varchar(256),
 year_eng float8,
 quarter_eng varchar(256),
 cat1_eng integer,
 cat2_eng integer,
 cat3_eng integer,
 cat1_sum_eng float8,
 cat2_sum_eng float8,
 cat3_sum_eng float8,
 segment_eng varchar(256),
 hospital_eng varchar(256),
 region_eng varchar(256),
 area_eng varchar(256),
 engagement_score_eng float8,
 rank_eng float8,
 phy_name_eng varchar(256)
);
 
CREATE TABLE ped_stg_usa.us_kol_overall_scoring ( 
 phy_name_us varchar(256),
 hospital_us varchar(256),
 city_us varchar(256),
 state_us varchar(256),
 us_area_us varchar(256),
 position_us varchar(256),
 segment_us varchar(256),
 email_us varchar(256),
 fellowship_us varchar(256),
 graduation_us varchar(256),
 emerging_us varchar(256),
 twitter_us varchar(256),
 eng_score_pct_us float8,
 sfdc_ytd_score_pct_us float8,
 sfdc_l4q_score_pct_us float8,
 pod_score_pct_us float8,
 soc_score_pct_us float8,
 pub_score_pct_us float8,
 ct_score_pct_us float8,
 influence_score_pct_us float8,
 partnership_score_pct_us float8,
 overall_score_pct_us float8 
);

 
CREATE TABLE ped_stg_usa.us_kol_open_payments ( record_id_op varchar(256),
 phy_name_op varchar(256),
 date_of_payment_op date,
 total_amount_of_payment_usdollars_op float country_of_travel_op varchar(256), 
 state_of_travel_op varchar(256) ,
 city_of_travel_op varchar(256),
 nature_of_payment_or_transfer_of_value_op varchar(256) ,
 applicable_manufacturer_or_applicable_gpo_making_payment_country_op varchar(256) ,
 applicable_manufacturer_or_applicable_gpo_making_payment_state_op varchar(256) ,
 sender_organization_op varchar(256) );

CREATE TABLE ped_stg_usa.us_kol_procedures
(
   sfdccallid          varchar(256),
   actualstartdate     timestamp,
   casetype            varchar(256),
   casesubtype         varchar(256),
   us_physician_names  varchar(256),
   sfdc_names          varchar(256),
   all_prod_names      varchar(1000),
   city                varchar(256),
   state               varchar(256),
   hospital            varchar(256),
   segment             varchar(256),
   global_region       varchar(256),
   us_area             varchar(256),
   last                varchar(256),
   first               varchar(256),
   last_4_qr           integer,
   emerging            varchar(256),
   curr_yr_flag        integer,
   prev_yr_flag        integer,
   rolling_12_mo       integer,
   psaf                integer,
   paf                 integer,
   afib                integer,
   vt                  integer,
   cartoprime          integer,
   smarttouch_sf       integer,
   soundstar           integer,
   pentaray            integer,
   surpoint            integer,
   vizigo              integer,
   qdot                integer,
   octaray             integer,
   nuvision            integer,
   optrell             integer,
   da_group            varchar(256),
   af_complex_svt      integer,
   oce                 integer,
   oce_2               integer,
   oce_3               integer,
   oce_4               integer,
   af_oce              integer,
   af_oce_2            integer,
   af_oce_3            integer,
   vt_oce_1            integer,
   vt_oce_2            integer,
   af_cartoprime       integer,
   af_pentaray         integer,
   af_stsf             integer,
   af_soundstar        integer,
   af_surpoint         integer,
   af_vizigo           integer,
   af_csvt_cartoprime  integer,
   vt_cartoprime       integer,
   vt_pentaray         integer,
   vt_stsf             integer,
   vt_soundstar        integer,
   vt_surpoint         integer,
   vt_vizigo           integer,
   af_curr_yr          integer,
   af_prev_yr          integer,
   vt_curr_yr          integer,
   vt_prev_yr          integer,
   af_roll_12          integer,
   vt_roll_12          integer,
   ytd_score           float8,
   last_4_qr_score     float8,
   phy_name            varchar(256),
   sfdc_refresh_date   varchar(256)
);