Define and compute shop visibility in SQL
Company: Meta
Role: Data Scientist
Category: Data Manipulation (SQL/Python)
Difficulty: medium
Interview Round: Onsite
You own the 'shop visibility' KPI for a marketplace. Define a precise metric and write SQL to compute it over the last 7 days (use today = 2025-09-01, so the window is 2025-08-26 to 2025-09-01 inclusive). Provide two related definitions: (A) visibility_rate = unique US users who saw ≥1 active product from a shop ÷ active US users; (B) impression_share = impressions of a shop's active products ÷ total impressions of all active products. Exclude deactivated products, deduplicate multiple impressions of the same product by the same user within a session, and restrict the denominator to 'active users' (users with ≥1 session in the window). Return: shop_id, visibility_rate, impression_share, unique_viewers, active_users, window_start, window_end. Then: (1) show how you'd parameterize this per-surface (feed vs shoppage), (2) handle late-arriving impressions and bot traffic, and (3) outline indexes or clustering to make the query efficient at 1B+ rows.
Schema and small ASCII samples you must use:
users(user_id INT, country STRING)
+---------+---------+
| user_id | country |
+---------+---------+
| 1 | US |
| 2 | US |
| 3 | CA |
| 4 | US |
+---------+---------+
shops(shop_id INT, name STRING)
+---------+----------+
| shop_id | name |
+---------+----------+
| 10 | Alpha |
| 20 | Beta |
+---------+----------+
products(product_id INT, shop_id INT, is_active BOOLEAN, created_at DATE)
+------------+---------+-----------+------------+
| product_id | shop_id | is_active | created_at |
+------------+---------+-----------+------------+
| 100 | 10 | true | 2025-08-01 |
| 101 | 10 | true | 2025-08-20 |
| 102 | 20 | true | 2025-07-15 |
| 103 | 20 | false | 2025-06-10 |
+------------+---------+-----------+------------+
impressions(impression_id BIGINT, ts TIMESTAMP, user_id INT, product_id INT, surface STRING)
+---------------+---------------------+---------+------------+----------+
| impression_id | ts | user_id | product_id | surface |
+---------------+---------------------+---------+------------+----------+
| 1 | 2025-08-26 10:00:00 | 1 | 100 | feed |
| 2 | 2025-08-27 11:00:00 | 2 | 100 | feed |
| 3 | 2025-08-27 12:00:00 | 2 | 101 | shoppage |
| 4 | 2025-08-28 09:00:00 | 4 | 102 | feed |
| 5 | 2025-09-01 13:00:00 | 1 | 102 | feed |
+---------------+---------------------+---------+------------+----------+
sessions(session_id BIGINT, user_id INT, session_start TIMESTAMP)
+------------+---------+---------------------+
| session_id | user_id | session_start |
+------------+---------+---------------------+
| 500 | 1 | 2025-08-28 08:00:00 |
| 501 | 2 | 2025-08-29 09:00:00 |
| 502 | 3 | 2025-08-30 10:00:00 |
| 503 | 4 | 2025-08-31 12:00:00 |
+------------+---------+---------------------+
Assume a SQL dialect with CTEs and DATE/TIMESTAMP functions. Write the full query for (A) and (B) and briefly explain how you'd adapt it for incremental daily jobs and backfills.
Overview: This question evaluates the ability to define and compute shop-level visibility KPIs in SQL, testing skills in metric design (visibility_rate and impression_share), deduplication, session/window filtering, and data-quality concerns such as late-arriving events and bot filtering.
Read the full Meta Data Scientist interview experience this question came from
Compute shop visibility_rate and impression_share (US, active users, last 7 days)
You own the “shop visibility” KPI for a marketplace.
Using today = 2025-09-01, compute metrics for the window 2025-08-26 to 2025-09-01 (inclusive).
Definitions (US only):
(A) visibility_rate = (unique active US users who saw ≥1 active product from a given shop) ÷ (active US users)
(B) impression_share = (deduplicated impressions of a shop’s active products) ÷ (deduplicated impressions of all active products)
Rules:
- Exclude deactivated products (products.is_active = true only).
- Restrict the denominator to “active users”: US users with ≥1 session in the window.
- Deduplicate multiple impressions of the same product by the same user within a session. Because impressions has no session_id, approximate “session” as (user_id, DATE(ts)). Deduplicate using (user_id, product_id, DATE(ts), surface) so repeated impressions in the same day/session count once.
Return one row per shop with these columns:
shop_id, visibility_rate, impression_share, unique_viewers, active_users, window_start, window_end
Notes:
- visibility_rate and impression_share should be decimals.
- Include shops even if they have zero impressions in the window (metrics should be 0 in that case).
Tables
users(user_id INT, country VARCHAR(2))
shops(shop_id INT, name VARCHAR(50))
products(product_id INT, shop_id INT, is_active BOOLEAN, created_at DATE)
impressions(impression_id BIGINT, ts TIMESTAMP, user_id INT, product_id INT, surface VARCHAR(20))
sessions(session_id BIGINT, user_id INT, session_start TIMESTAMP)
Hints
- Build an active US user set from sessions first; it will be the denominator for visibility_rate.
- Deduplicate impressions before joining to products; then filter products.is_active = true.
Parameterize the KPI by surface (example: compute only for surface = 'feed')
Compute the same output as in Question 1, but parameterized for a single surface.
Use surface = 'feed' for this question. Apply the surface filter to impressions before deduplication.
Return:
shop_id, surface, visibility_rate, impression_share, unique_viewers, active_users, window_start, window_end
Notes:
- Active users are still defined from sessions (US users with ≥1 session in the window), independent of surface.
- Include shops even if they have zero impressions on that surface in the window.
Tables
users(user_id INT, country VARCHAR(2))
shops(shop_id INT, name VARCHAR(50))
products(product_id INT, shop_id INT, is_active BOOLEAN, created_at DATE)
impressions(impression_id BIGINT, ts TIMESTAMP, user_id INT, product_id INT, surface VARCHAR(20))
sessions(session_id BIGINT, user_id INT, session_start TIMESTAMP)
Hints
- Treat surface as a parameter (e.g., a one-row CTE or bind variable) and filter impressions early.
- Compute impression_share relative to the total impressions after applying the same surface filter.