Tables

-- Create from a query
CREATE TABLE oleander.default.my_table AS
SELECT * FROM oleander.default.source_table WHERE region = 'us-west-2';

-- Time-travel query
SELECT * FROM oleander.default.my_table
AT (TIMESTAMP => now() - INTERVAL '7 DAYS');

-- Recent pipeline failures
SELECT job.name, run.run_id, event_time
FROM oleander.telemetry.run_events
WHERE event_type = 'FAIL'
  AND event_time > now() - INTERVAL '24 HOURS'
ORDER BY event_time DESC;

-- Slow spans
SELECT span_name, start_time, end_time,
       epoch_ms(end_time - start_time) / 1000.0 AS duration_sec
FROM oleander.telemetry.traces
WHERE start_time > now() - INTERVAL '1 HOUR'
ORDER BY duration_sec DESC
LIMIT 20;

-- Error logs
SELECT time, severity, body
FROM oleander.telemetry.logs
WHERE severity = 'ERROR'
  AND time > now() - INTERVAL '1 HOUR';

-- Join your lake data with BigQuery
SELECT l.user_id, b.plan_name
FROM oleander.default.signups l
JOIN my_bq_connection.analytics.plans b ON l.plan_id = b.id;