1- SET allow_experimental_object_type = 1 ;
2-
31-- Create Event
42CREATE TABLE umami .website_event
53(
@@ -34,82 +32,6 @@ CREATE TABLE umami.website_event
3432 ORDER BY (website_id, session_id, created_at)
3533 SETTINGS index_granularity = 8192 ;
3634
37- CREATE TABLE umami .website_event_queue (
38- website_id UUID,
39- session_id UUID,
40- event_id UUID,
41- -- sessions
42- hostname LowCardinality(String),
43- browser LowCardinality(String),
44- os LowCardinality(String),
45- device LowCardinality(String),
46- screen LowCardinality(String),
47- language LowCardinality(String),
48- country LowCardinality(String),
49- subdivision1 LowCardinality(String),
50- subdivision2 LowCardinality(String),
51- city String,
52- -- pageviews
53- url_path String,
54- url_query String,
55- referrer_path String,
56- referrer_query String,
57- referrer_domain String,
58- page_title String,
59- -- events
60- event_type UInt32,
61- event_name String,
62- created_at DateTime(' UTC' ),
63- -- virtual columns
64- _error String,
65- _raw_message String
66- )
67- ENGINE = Kafka
68- SETTINGS kafka_broker_list = ' domain:9092,domain:9093,domain:9094' , -- input broker list
69- kafka_topic_list = ' event' ,
70- kafka_group_name = ' event_consumer_group' ,
71- kafka_format = ' JSONEachRow' ,
72- kafka_max_block_size = 1048576 ,
73- kafka_handle_error_mode = ' stream' ;
74-
75- CREATE MATERIALIZED VIEW umami .website_event_queue_mv TO umami .website_event AS
76- SELECT website_id,
77- session_id,
78- event_id,
79- hostname,
80- browser,
81- os,
82- device,
83- screen,
84- language,
85- country,
86- subdivision1,
87- subdivision2,
88- city,
89- url_path,
90- url_query,
91- referrer_path,
92- referrer_query,
93- referrer_domain,
94- page_title,
95- event_type,
96- event_name,
97- created_at
98- FROM umami .website_event_queue ;
99-
100- CREATE MATERIALIZED VIEW umami .website_event_errors_mv
101- (
102- error String,
103- raw String
104- )
105- ENGINE = MergeTree
106- ORDER BY (error, raw)
107- SETTINGS index_granularity = 8192 AS
108- SELECT _error AS error,
109- _raw_message AS raw
110- FROM umami .website_event_queue
111- WHERE length(_error) > 0 ;
112-
11335CREATE TABLE umami .event_data
11436(
11537 website_id UUID,
@@ -127,55 +49,4 @@ CREATE TABLE umami.event_data
12749)
12850 engine = MergeTree
12951 ORDER BY (website_id, event_id, event_key, created_at)
130- SETTINGS index_granularity = 8192 ;
131-
132- CREATE TABLE umami .event_data_queue (
133- website_id UUID,
134- session_id UUID,
135- event_id UUID,
136- url_path String,
137- event_name String,
138- event_key String,
139- string_value Nullable(String),
140- number_value Nullable(Decimal64(4 )), -- 922337203685477.5625
141- date_value Nullable(DateTime(' UTC' )),
142- data_type UInt32,
143- created_at DateTime(' UTC' ),
144- -- virtual columns
145- _error String,
146- _raw_message String
147- )
148- ENGINE = Kafka
149- SETTINGS kafka_broker_list = ' domain:9092,domain:9093,domain:9094' , -- input broker list
150- kafka_topic_list = ' event_data' ,
151- kafka_group_name = ' event_data_consumer_group' ,
152- kafka_format = ' JSONEachRow' ,
153- kafka_max_block_size = 1048576 ,
154- kafka_handle_error_mode = ' stream' ;
155-
156- CREATE MATERIALIZED VIEW umami .event_data_queue_mv TO umami .event_data AS
157- SELECT website_id,
158- session_id,
159- event_id,
160- url_path,
161- event_name,
162- event_key,
163- string_value,
164- number_value,
165- date_value,
166- data_type,
167- created_at
168- FROM umami .event_data_queue ;
169-
170- CREATE MATERIALIZED VIEW umami .event_data_errors_mv
171- (
172- error String,
173- raw String
174- )
175- ENGINE = MergeTree
176- ORDER BY (error, raw)
177- SETTINGS index_granularity = 8192 AS
178- SELECT _error AS error,
179- _raw_message AS raw
180- FROM umami .event_data_queue
181- WHERE length(_error) > 0 ;
52+ SETTINGS index_granularity = 8192 ;
0 commit comments