Skip to content

Commit 18d9905

Browse files
committed
fix: add sql
1 parent b86c7a4 commit 18d9905

File tree

1 file changed

+47
-0
lines changed

1 file changed

+47
-0
lines changed
Lines changed: 47 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,47 @@
1+
CREATE TABLE IF NOT EXISTS events_imports_replicated ON CLUSTER '{cluster}' (
2+
`id` UUID DEFAULT generateUUIDv4(),
3+
`name` LowCardinality(String),
4+
`sdk_name` LowCardinality(String),
5+
`sdk_version` LowCardinality(String),
6+
`device_id` String CODEC(ZSTD(3)),
7+
`profile_id` String CODEC(ZSTD(3)),
8+
`project_id` String CODEC(ZSTD(3)),
9+
`session_id` String CODEC(LZ4),
10+
`path` String CODEC(ZSTD(3)),
11+
`origin` String CODEC(ZSTD(3)),
12+
`referrer` String CODEC(ZSTD(3)),
13+
`referrer_name` String CODEC(ZSTD(3)),
14+
`referrer_type` LowCardinality(String),
15+
`duration` UInt64 CODEC(Delta(4), LZ4),
16+
`properties` Map(String, String) CODEC(ZSTD(3)),
17+
`created_at` DateTime64(3) CODEC(DoubleDelta, ZSTD(3)),
18+
`country` LowCardinality(FixedString(2)),
19+
`city` String,
20+
`region` LowCardinality(String),
21+
`longitude` Nullable(Float32) CODEC(Gorilla, LZ4),
22+
`latitude` Nullable(Float32) CODEC(Gorilla, LZ4),
23+
`os` LowCardinality(String),
24+
`os_version` LowCardinality(String),
25+
`browser` LowCardinality(String),
26+
`browser_version` LowCardinality(String),
27+
`device` LowCardinality(String),
28+
`brand` LowCardinality(String),
29+
`model` LowCardinality(String),
30+
`imported_at` Nullable(DateTime) CODEC(Delta(4), LZ4),
31+
`import_id` String CODEC(ZSTD(3)),
32+
`import_status` LowCardinality(String) DEFAULT 'pending',
33+
`imported_at_meta` DateTime DEFAULT now()
34+
)
35+
ENGINE = ReplicatedMergeTree('/clickhouse/{installation}/{cluster}/tables/{shard}/openpanel/v1/{table}', '{replica}')
36+
PARTITION BY toYYYYMM(imported_at_meta)
37+
ORDER BY (import_id, created_at)
38+
SETTINGS index_granularity = 8192;
39+
40+
---
41+
42+
CREATE TABLE IF NOT EXISTS events_imports ON CLUSTER '{cluster}' AS events_imports_replicated
43+
ENGINE = Distributed('{cluster}', currentDatabase(), events_imports_replicated, cityHash64(import_id));
44+
45+
---
46+
47+
ALTER TABLE events_imports_replicated ON CLUSTER '{cluster}' MODIFY TTL imported_at_meta + INTERVAL 7 DAY;

0 commit comments

Comments
 (0)