--! qt:dataset:src
SET hive.vectorized.execution.enabled=false;
SET hive.auto.convert.join=true;
SET hive.auto.convert.join.noconditionaltask=true;
SET hive.auto.convert.join.noconditionaltask.size=1000000000;
set hive.mapjoin.optimized.hashtable=true;
set hive.mapred.mode=nonstrict;
create table service_request_clean(
cnctevn_id          	string              ,
svcrqst_id          	string              ,
svcrqst_crt_dts     	string              ,
subject_seq_no      	int                 ,
plan_component      	string              ,
cust_segment        	string              ,
cnctyp_cd           	string              ,
cnctmd_cd           	string              ,
cnctevs_cd          	string              ,
svcrtyp_cd          	string              ,
svrstyp_cd          	string              ,
cmpltyp_cd          	string              ,
catsrsn_cd          	string              ,
apealvl_cd          	string              ,
cnstnty_cd          	string              ,
svcrqst_asrqst_ind  	string              ,
svcrqst_rtnorig_in  	string              ,
svcrqst_vwasof_dt   	string              ,
sum_reason_cd       	string              ,
sum_reason          	string              ,
crsr_master_claim_index	string              ,
svcrqct_cds         	array<string>       ,
svcrqst_lupdt       	string              ,
crsr_lupdt          	timestamp           ,
cntevsds_lupdt      	string              ,
ignore_me           	int                 ,
notes               	array<string>       )
ROW FORMAT DELIMITED 
FIELDS TERMINATED BY  '\t' LINES TERMINATED BY '\n' 
STORED AS TEXTFILE;

load data local inpath '../../data/files/service_request_clean.txt' into table service_request_clean;

create table ct_events_clean(
contact_event_id    	string              ,
ce_create_dt        	string              ,
ce_end_dt           	string              ,
contact_type        	string              ,
cnctevs_cd          	string              ,
contact_mode        	string              ,
cntvnst_stts_cd     	string              ,
total_transfers     	int                 ,
ce_notes            	array<string>       )
ROW FORMAT DELIMITED 
FIELDS TERMINATED BY  '\t' LINES TERMINATED BY '\n' 
STORED AS TEXTFILE;

load data local inpath '../../data/files/ct_events_clean.txt' into table ct_events_clean;

set hive.mapjoin.hybridgrace.hashtable=false;
drop table if exists ct_events1_test;

explain extended
create table ct_events1_test
as select  a.*,
b.svcrqst_id,
b.svcrqct_cds,
b.svcrtyp_cd,
b.cmpltyp_cd,
b.sum_reason_cd as src,
b.cnctmd_cd,
b.notes
from ct_events_clean a
inner join
service_request_clean b
on a.contact_event_id = b.cnctevn_id;

-- SORT_QUERY_RESULTS

create table ct_events1_test
as select  a.*,
b.svcrqst_id,
b.svcrqct_cds,
b.svcrtyp_cd,
b.cmpltyp_cd,
b.sum_reason_cd as src,
b.cnctmd_cd,
b.notes
from ct_events_clean a
inner join
service_request_clean b
on a.contact_event_id = b.cnctevn_id;

select * from ct_events1_test;

set hive.mapjoin.hybridgrace.hashtable=true;
drop table if exists ct_events1_test;

explain extended
create table ct_events1_test
as select  a.*,
b.svcrqst_id,
b.svcrqct_cds,
b.svcrtyp_cd,
b.cmpltyp_cd,
b.sum_reason_cd as src,
b.cnctmd_cd,
b.notes
from ct_events_clean a
inner join
service_request_clean b
on a.contact_event_id = b.cnctevn_id;

-- SORT_QUERY_RESULTS

create table ct_events1_test
as select  a.*,
b.svcrqst_id,
b.svcrqct_cds,
b.svcrtyp_cd,
b.cmpltyp_cd,
b.sum_reason_cd as src,
b.cnctmd_cd,
b.notes
from ct_events_clean a
inner join
service_request_clean b
on a.contact_event_id = b.cnctevn_id;

select * from ct_events1_test;