Unit Count (Latest Value) Metrics

-- Unit Level
SELECT
  unit_id,
  group_id,
  if(passes_filter, 1, 0) as value
FROM (
    SELECT
        source_data.*,
        exposures_data.group_id,
        source_data.date = MAX(source_data.date) over (partition by source_data.unit_id) as is_latest_date
    FROM source_data
    JOIN exposure_data
    ON
      -- Only include users who saw the experiment
      source_data.unit_id = exposure_data.unit_id
      -- Only include data from after the user saw the experiment
      -- In this case exposure_data is already deduped to the "first exposure"
      AND source_data.timestamp >= exposure_data.timestamp
)
WHERE is_latest_date = 1
GROUP BY
  source_data.unit_id,
  exposure_data.group_id;

-- Experiment
SELECT
  group_id,
  COUNT(distinct unit_id) total_units
FROM exposure_data
GROUP BY group_id;

-- Group Level
SELECT
  group_id,
  SUM(value)/SUM(total_units) as mean
FROM unit_data
JOIN group_data
USING (group_id)
GROUP BY group_id;