@@ -115,3 +115,34 @@ CREATE TABLE ooni.obs_openvpn
115115ENGINE = ReplacingMergeTree(measurement_start_time)
116116ORDER BY (measurement_start_time, report_id, input)
117117SETTINGS index_granularity = 8 ;
118+
119+ CREATE TABLE ooni .event_detector_cusums
120+ (
121+ ` probe_asn` UInt32,
122+ ` probe_cc` String,
123+ ` domain` String,
124+ ` ts` DateTime64(3 , ' UTC' ),
125+ ` dns_isp_blocked_current_state` String DEFAULT ' ok' ,
126+ ` dns_isp_blocked_s_pos` Nullable(Float64),
127+ ` dns_isp_blocked_s_neg` Nullable(Float64),
128+ ` dns_other_blocked_current_state` String DEFAULT ' ok' ,
129+ ` dns_other_blocked_s_pos` Nullable(Float64),
130+ ` dns_other_blocked_s_neg` Nullable(Float64),
131+ ` tcp_blocked_current_state` String DEFAULT ' ok' ,
132+ ` tcp_blocked_s_pos` Nullable(Float64),
133+ ` tcp_blocked_s_neg` Nullable(Float64),
134+ ` tls_blocked_current_state` String DEFAULT ' ok' ,
135+ ` tls_blocked_s_pos` Nullable(Float64),
136+ ` tls_blocked_s_neg` Nullable(Float64),
137+ ` dns_isp_blocked_last_change` Int8 DEFAULT 0 ,
138+ ` dns_isp_blocked_last_ts` Nullable(DateTime64(3 , ' UTC' )),
139+ ` dns_other_blocked_last_change` Int8 DEFAULT 0 ,
140+ ` dns_other_blocked_last_ts` Nullable(DateTime64(3 , ' UTC' )),
141+ ` tcp_blocked_last_change` Int8 DEFAULT 0 ,
142+ ` tcp_blocked_last_ts` Nullable(DateTime64(3 , ' UTC' )),
143+ ` tls_blocked_last_change` Int8 DEFAULT 0 ,
144+ ` tls_blocked_last_ts` Nullable(DateTime64(3 , ' UTC' ))
145+ )
146+ ENGINE = ReplacingMergeTree(ts)
147+ ORDER BY (probe_asn, probe_cc, domain)
148+ SETTINGS index_granularity = 8192 ;
0 commit comments