You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: load_scripts/bluesky/clickhouse_ddl/medallion/03_gold/Readme.md
+4-4Lines changed: 4 additions & 4 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -159,7 +159,7 @@ CREATE MATERIALIZED VIEW bluesky.displayName_per_user_mv TO bluesky.displayName_
159
159
ASSELECT
160
160
data.didas did,
161
161
argMax(data.commit.record.displayName, bluesky_ts) as displayName
162
-
FROM bluesky
162
+
FROMbluesky.bluesky
163
163
WHERE (kind ='commit') AND (data.commit.collection ='app.bsky.actor.profile') AND notEmpty(data.commit.record.displayName) AND (data.commit.operation ='update'ORdata.commit.operation ='create')
164
164
GROUP BYdata.did;
165
165
```
@@ -170,7 +170,7 @@ INSERT INTO bluesky.displayName_per_user
170
170
SELECT
171
171
data.didas did,
172
172
argMax(data.commit.record.displayName, bluesky_ts) as displayName
173
-
FROM bluesky
173
+
FROMbluesky.bluesky
174
174
WHERE (kind ='commit') AND (data.commit.collection ='app.bsky.actor.profile') AND notEmpty(data.commit.record.displayName) AND (data.commit.operation ='update'ORdata.commit.operation ='create')
175
175
GROUP BYdata.did;
176
176
```
@@ -544,7 +544,7 @@ CREATE MATERIALIZED VIEW bluesky.posts_per_language_mv TO bluesky.posts_per_lang
544
544
ASSELECT
545
545
arrayJoin(CAST(data.commit.record.langs, 'Array(String)')) AS language,
546
546
count() AS posts
547
-
FROM bluesky
547
+
FROMbluesky.bluesky
548
548
WHEREdata.commit.collection ='app.bsky.feed.post'
549
549
GROUP BY language;
550
550
```
@@ -556,7 +556,7 @@ INSERT INTO bluesky.posts_per_language
556
556
SELECT
557
557
arrayJoin(CAST(data.commit.record.langs, 'Array(String)')) AS language,
0 commit comments