Method unit_select

api/experimentation/results_query.py:85–100

Per-identity expression for the unit_values CTE SELECT.

(self)

        )

    def unit_select(self) -> str:
        """Per-identity expression for the unit_values CTE SELECT."""
        cond = self._condition()
        agg = self.spec.aggregation
        if agg == MetricAggregation.OCCURRENCE:
            return f"countIf({cond}) > 0 AS {self._alias}"
        if agg == MetricAggregation.COUNT:
            return f"countIf({cond}) AS {self._alias}"
        if agg == MetricAggregation.SUM:
            return f"sumIf({_FLOAT_VALUE}, {cond}) AS {self._alias}"
        if agg == MetricAggregation.MEAN:
            return (
                f"if(countIf({cond}) > 0, avgIf({_FLOAT_VALUE}, {cond}), 0)"
                f" AS {self._alias}"
            )
        raise ValueError(f"Unsupported metric aggregation: {agg}")

    def outer_select(self) -> str:
        """Sufficient-stat aggregates for the final SELECT."""