{{const-endpointFilter}} AND duration != null
| summarize percentiles(duration / 1e6, 50, 75, 90, 95, 99) by bin_auto(timestamp)
| order by timestamp desc

WITH endpoint_spans AS (
  SELECT
    extract(epoch from time_bucket('{{rollup_interval}}', timestamp))::integer AS time,
    context___span_id as span_id,
    context___trace_id as trace_id
  FROM otel_logs_and_spans
  WHERE project_id='{{project_id}}'
    AND {{const-endpointFilter}}
    {{time_filter}}
),
downstream_time AS (
  SELECT
    es.time,
    o.name as operation,
    SUM(o.duration)::float as duration_ns
  FROM otel_logs_and_spans o
  INNER JOIN endpoint_spans es ON o.context___trace_id = es.trace_id
  WHERE o.project_id='{{project_id}}'
    AND o.parent_id = es.span_id
    AND o.duration IS NOT NULL
    AND o.name IS NOT NULL
    {{time_filter}}
  GROUP BY es.time, o.name
)
SELECT time, operation, duration_ns as value
FROM downstream_time
ORDER BY time DESC
LIMIT 10000