gnb_id,
0 as event_type
from SGNB_ADDITION_REQ.sgnb_addreq_for_ue
-// where schemaId=401
;
DEFINE{query_name 'reconfig_status_success';
gnb_id,
1 as event_type
from RECONCOMPLETE.reconfig_success
-// where schemaId=101
;
DEFINE{query_name 'reconfig_status_events';}
($window*(TB+1))/1000 as TS,
$window/1000.0 as measurementInterval,
count(*) as total_reconfiguration_requests,
- sum(GEQ(max_end_time,ULLONG(1))) as successful_reconfiguration_requests,
- FLOAT(sum(GEQ(max_end_time,ULLONG(1))))/count(*) as success_rate
+ sum( GEQ(max_end_time,1) ) as successful_reconfiguration_requests,
+ (1.0*sum( GEQ( max_end_time,1) ))/count(*) as success_rate,
+ 1.0 - ( (1.0*sum( GEQ( max_end_time,1) ))/count(*) ) as failure_rate
from reconfig_status_merge
group by gnb_id, TB
;
+DEFINE{query_name 'reconfig_status_join';
+ max_lfta_disorder '1'; max_hfta_disorder '1';
+ comment 'Associate gtp_teid using eUE_ID';
+}
+PARAM{ window uint; }
+Select r.eUE_ID, M.gTP_TEID, r.gnb_id, r.TB,
+ r.max_start_time, r.max_end_time
+INNER_JOIN from reconfig_status_merge r, gnb_ueid_teid_map M
+where r.eUE_ID=M.id_MeNB_UE_X2AP_ID and r.gnb_id=M.GNB_ID and r.TB=M.TB
+;
+
+DEFINE{query_name 'reconfig_status_success_rate_gtp_teid';
+ max_lfta_disorder '1'; max_hfta_disorder '1';
+ comment 'fraction of DC connect requests which are successful, on a per-user (gtp_teid) basis.';
+}
+PARAM{ window uint; }
+select gnb_id as GNB_ID, gTP_TEID,
+ ($window*(TB+1))/1000 as TS,
+ $window/1000.0 as measurementInterval,
+ count(*) as total_reconfiguration_requests,
+ sum( GEQ(max_end_time,1) ) as successful_reconfiguration_requests,
+ (1.0*sum( GEQ( max_end_time,1) ))/count(*) as success_rate,
+ 1.0 - ( (1.0*sum( GEQ( max_end_time,1) ))/count(*) ) as failure_rate
+from reconfig_status_join
+group by gnb_id, gTP_TEID, TB
+;
+
+
// ----------------------------------------------
// Merge in reconfig_reject causes and aggregate with this.
DEFINE{query_name 'reconfig_status_reject_cause';
comment 'distribution of causes for DC rejection';
}
PARAM{ window uint; }
-Select gnb_id, TB,
+Select gnb_id as GNB_ID, TB,
count(*) as total_reconfig_reject,
- sum(GEQ(UINT(cause_radio_network),0)) as count_radio_network,
- sum(GEQ(UINT(cause_transport),0)) as count_transport,
- sum(GEQ(UINT(cause_protocol),0)) as count_protocol,
- sum(GEQ(UINT(cause_misc),0)) as count_misc
+ sum( GEQ(cause_radio_network,0) ) as count_radio_network,
+ sum( GEQ(cause_transport,0) ) as count_transport,
+ sum( GEQ(cause_protocol,0) ) as count_protocol,
+ sum( GEQ(cause_misc,0) ) as count_misc
from ADDREQREJECT.sgnb_add_req_reject
-// where schemaId=701
group by gnb_id, timestamp_ms / $window as TB
;
+DEFINE{query_name 'reconfig_status_reject_join';
+ max_lfta_disorder '1'; max_hfta_disorder '1';
+ comment 'Associate gtp_teid using eUE_ID';
+}
+PARAM{ window uint; }
+Select r.id_MeNB_UE_X2AP_ID, M.gTP_TEID, r.gnb_id, M.TB,
+ r.cause_radio_network, r.cause_transport,
+ r.cause_protocol, r.cause_misc
+INNER_JOIN from ADDREQREJECT.sgnb_add_req_reject r, gnb_ueid_teid_map M
+where r.id_MeNB_UE_X2AP_ID=M.id_MeNB_UE_X2AP_ID and r.gnb_id=M.GNB_ID
+ and r.timestamp_ms/$window=M.TB
+;
+
+DEFINE{query_name 'reconfig_status_reject_cause_gtp_teid';
+ max_lfta_disorder '1'; max_hfta_disorder '1';
+ comment 'distribution of causes for DC rejection on a per-ue (gtp-teid) basis';
+}
+PARAM{ window uint; }
+Select gnb_id as GNB_ID, gTP_TEID, TB,
+ count(*) as total_reconfig_reject,
+ sum( GEQ(cause_radio_network,0) ) as count_radio_network,
+ sum( GEQ(cause_transport,0) ) as count_transport,
+ sum( GEQ(cause_protocol,0) ) as count_protocol,
+ sum( GEQ(cause_misc,0) ) as count_misc
+from reconfig_status_reject_join
+group by gnb_id, gTP_TEID, TB
+;
+
DEFINE{query_name 'reconfig_complete_reject_cause';
max_lfta_disorder '1'; max_hfta_disorder '1';
}
PARAM{ window uint; }
Select gnb_id, TB,
count(*) as total_reconfig_reject,
- sum(GEQ(UINT(cause_radio_network),0)) as count_radio_network,
- sum(GEQ(UINT(cause_transport),0)) as count_transport,
- sum(GEQ(UINT(cause_protocol),0)) as count_protocol,
- sum(GEQ(UINT(cause_misc),0)) as count_misc
+ sum( GEQ(cause_radio_network,0) ) as count_radio_network,
+ sum( GEQ(cause_transport,0) ) as count_transport,
+ sum( GEQ(cause_protocol,0) ) as count_protocol,
+ sum( GEQ(cause_misc,0) ) as count_misc
from RECONCOMPLETE.reconfig_reject
-// where schemaId=102
group by gnb_id, timestamp_ms / $window as TB
;
// ----------------------------------------------
+DEFINE{query_name 'mod_status_refuse_cause_base';
+ max_lfta_disorder '1'; max_hfta_disorder '1';
+ comment 'distribution of causes for a sgnb modification refusal (base)';
+}
+PARAM{ window uint; }
+Select gnb_id as GNB_ID, TB,
+ id_MeNB_UE_X2AP_ID, id_SgNB_UE_X2AP_ID,
+ count(*) as total_reconfig_refuse,
+ sum( GEQ(cause_radio_network,0) ) as count_radio_network,
+ sum( GEQ(cause_transport,0) ) as count_transport,
+ sum( GEQ(cause_protocol,0) ) as count_protocol,
+ sum( GEQ(cause_misc,0) ) as count_misc
+from SGNBMODREFUSE.sgnb_mod_refuse
+group by gnb_id, timestamp_ms / $window as TB,
+ id_MeNB_UE_X2AP_ID, id_SgNB_UE_X2AP_ID
+;
+
DEFINE{query_name 'mod_status_refuse_cause';
max_lfta_disorder '1'; max_hfta_disorder '1';
- comment 'distribution of causes for a sgnb modification refusal';
+ comment 'distribution of causes for a sgnb modification refusal (base)';
}
PARAM{ window uint; }
-Select gnb_id as GNB_ID, ($window*(TB+1))/1000 as TS,
+Select GNB_ID, ($window*(TB+1))/1000 as TS,
$window/1000.0 as measurementInterval,
+ sum(total_reconfig_refuse) as total_reconfig_refuse,
+ sum( count_radio_network ) as count_radio_network,
+ sum( count_transport ) as count_transport,
+ sum( count_protocol ) as count_protocol,
+ sum( count_misc ) as count_misc
+from mod_status_refuse_cause_base
+group by GNB_ID, TB
+;
+
+DEFINE{query_name 'mod_req_reject_cause_base';
+ max_lfta_disorder '1'; max_hfta_disorder '1';
+ comment 'distribution of causes for a sgnb modification request reject (base)';
+}
+PARAM{ window uint; }
+Select gnb_id as GNB_ID, TB,
+ id_MeNB_UE_X2AP_ID, id_SgNB_UE_X2AP_ID,
count(*) as total_reconfig_refuse,
- sum(GEQ(UINT(cause_radio_network),0)) as count_radio_network,
- sum(GEQ(UINT(cause_transport),0)) as count_transport,
- sum(GEQ(UINT(cause_protocol),0)) as count_protocol,
- sum(GEQ(UINT(cause_misc),0)) as count_misc
-from SGNBMODREFUSE.sgnb_mod_refuse
-// where schemaId=1401
-group by gnb_id, timestamp_ms / $window as TB
+ sum( GEQ(cause_radio_network,0) ) as count_radio_network,
+ sum( GEQ(cause_transport,0) ) as count_transport,
+ sum( GEQ(cause_protocol,0) ) as count_protocol,
+ sum( GEQ(cause_misc,0) ) as count_misc
+from SGNBMODREQREJECT.sgnb_mod_req_reject
+group by gnb_id, timestamp_ms / $window as TB,
+ id_MeNB_UE_X2AP_ID, id_SgNB_UE_X2AP_ID
;
+DEFINE{query_name 'mod_status_refuse_cause_base_gtp_teid';
+ max_lfta_disorder '1'; max_hfta_disorder '1';
+ comment 'distribution of causes for a sgnb modification refusal (base), labeled with gtp_teid';
+}
+PARAM{ window uint; }
+Select b.GNB_ID, b.TB,
+ m.gTP_TEID,
+ b.total_reconfig_refuse,
+ b.count_radio_network,
+ b.count_transport,
+ b.count_protocol,
+ b.count_misc
+LEFT_OUTER_JOIN from mod_status_refuse_cause_base b,
+ gnb_ueid_teid_map m
+where b.TB=m.TB and b.GNB_ID=m.GNB_ID and
+ b.id_MeNB_UE_X2AP_ID=m.id_MeNB_UE_X2AP_ID
+;
+
+DEFINE{query_name 'mod_req_reject_cause_base_gtp_teid';
+ max_lfta_disorder '1'; max_hfta_disorder '1';
+ comment 'distribution of causes for a sgnb modification request reject (base), labeled with gtp_teid';
+}
+PARAM{ window uint; }
+Select b.GNB_ID, b.TB,
+ m.gTP_TEID,
+ b.total_reconfig_refuse,
+ b.count_radio_network,
+ b.count_transport,
+ b.count_protocol,
+ b.count_misc
+LEFT_OUTER_JOIN from mod_req_reject_cause_base b,
+ gnb_ueid_teid_map m
+where b.TB=m.TB and b.GNB_ID=m.GNB_ID and
+ b.id_MeNB_UE_X2AP_ID=m.id_MeNB_UE_X2AP_ID
+;
+
+DEFINE{query_name 'mod_failure_cause_merge';
+ max_lfta_disorder '1'; max_hfta_disorder '1';
+ comment 'distribution of causes for a sgnb modification request reject (base), labeled with gtp_teid';
+}
+PARAM{ window uint; }
+merge p1.TB : p2.TB
+from mod_req_reject_cause_base_gtp_teid p1, mod_status_refuse_cause_base_gtp_teid p2
+;
+
+DEFINE{query_name 'mod_failure_cause_gtp_teid';
+ max_lfta_disorder '1'; max_hfta_disorder '1';
+ comment 'distribution of causes for a sgnb modification failure, by UE (gtp_teid)';
+}
+PARAM{ window uint; }
+Select GNB_ID, gTP_TEID, ($window*(TB+1))/1000 as TS,
+ $window/1000.0 as measurementInterval,
+ sum(total_reconfig_refuse) as total_reconfig_refuse,
+ sum( count_radio_network ) as count_radio_network,
+ sum( count_transport ) as count_transport,
+ sum( count_protocol ) as count_protocol,
+ sum( count_misc ) as count_misc
+from mod_failure_cause_merge
+group by GNB_ID, gTP_TEID, TB
+;
+
+
// ----------------------------------------------
-DEFINE{query_name 'release_rqd_cause';
+
+DEFINE{query_name 'release_rqd_cause_base';
max_lfta_disorder '1'; max_hfta_disorder '1';
}
PARAM{ window uint; }
-Select gnb_id, TB,
+Select gnb_id, TB, id_MeNB_UE_X2AP_ID,
count(*) as total_reconfig_refuse,
- sum(GEQ(UINT(cause_radio_network),0)) as count_radio_network,
- sum(GEQ(UINT(cause_transport),0)) as count_transport,
- sum(GEQ(UINT(cause_protocol),0)) as count_protocol,
- sum(GEQ(UINT(cause_misc),0)) as count_misc
+ sum( GEQ(cause_radio_network,0) ) as count_radio_network,
+ sum( GEQ(cause_transport,0) ) as count_transport,
+ sum( GEQ(cause_protocol,0) ) as count_protocol,
+ sum( GEQ(cause_misc,0) ) as count_misc
from SGNBRELEASERQD.SgNB_release_rqd
-// where schemaId=1001
-group by gnb_id, timestamp_ms / $window as TB
+group by gnb_id, timestamp_ms / $window as TB, id_MeNB_UE_X2AP_ID
;
-DEFINE{query_name 'release_request_cause';
+DEFINE{query_name 'release_request_cause_base';
max_lfta_disorder '1'; max_hfta_disorder '1';
}
PARAM{ window uint; }
-Select gnb_id, TB,
+Select gnb_id, TB, id_MeNB_UE_X2AP_ID,
count(*) as total_reconfig_refuse,
- sum(GEQ(UINT(cause_radio_network),0)) as count_radio_network,
- sum(GEQ(UINT(cause_transport),0)) as count_transport,
- sum(GEQ(UINT(cause_protocol),0)) as count_protocol,
- sum(GEQ(UINT(cause_misc),0)) as count_misc
+ sum( GEQ(cause_radio_network,0) ) as count_radio_network,
+ sum( GEQ(cause_transport,0) ) as count_transport,
+ sum( GEQ(cause_protocol,0) ) as count_protocol,
+ sum( GEQ(cause_misc,0) ) as count_misc
from RELREQ.release_req
-// where schemaId=801
-group by gnb_id, timestamp_ms / $window as TB
+group by gnb_id, timestamp_ms / $window as TB, id_MeNB_UE_X2AP_ID
;
DEFINE{query_name 'reconfig_cause_merge';}
PARAM{ window uint; }
merge p1.TB : p2.TB
-from release_rqd_cause p1, release_request_cause p2
+from release_rqd_cause_base p1, release_request_cause_base p2
;
DEFINE{query_name 'release_cause';
sum(count_misc) as count_misc
from reconfig_cause_merge
group by gnb_id, TB
+;
+
+DEFINE{query_name 'release_cause_join';
+ max_lfta_disorder '1'; max_hfta_disorder '1';
+ comment 'distribution of the causes of a DC release';
+}
+PARAM{ window uint; }
+Select r.gnb_id, r.TB, m.gTP_TEID,
+ r.total_reconfig_refuse, r.count_radio_network,
+ r.count_transport, r.count_protocol, r.count_misc
+LEFT_OUTER_JOIN from reconfig_cause_merge r, gnb_ueid_teid_map m
+Where r.gnb_id=m.GNB_ID and r.id_MeNB_UE_X2AP_ID=m.id_MeNB_UE_X2AP_ID
+ and r.TB=m.TB
+;
+
+DEFINE{query_name 'release_cause_gtp_ueid';
+ max_lfta_disorder '1'; max_hfta_disorder '1';
+ comment 'distribution of the causes of a DC release by UE (gtp_teid)';
+}
+PARAM{ window uint; }
+Select gnb_id as GNB_ID, gTP_TEID, ($window*(TB+1))/1000 as TS,
+ $window/1000.0 as measurementInterval,
+ sum(total_reconfig_refuse) as total_reconfig_refuse,
+ sum(count_radio_network) as count_radio_network,
+ sum(count_transport) as count_transport,
+ sum(count_protocol) as count_protocol,
+ sum(count_misc) as count_misc
+from release_cause_join
+group by gnb_id, TB, gTP_TEID
+
Code Review / ric-app / mc.git / blobdiff