Starburst Enterprise

-- Example: Recent high-value events across catalogs
SELECT
    event_name,
    user_id,
    event_timestamp,
    CAST(event_properties AS JSON) as event_properties
FROM catalog.schema.user_events
WHERE event_timestamp >= current_timestamp - INTERVAL '7' DAY
    AND JSON_EXTRACT_SCALAR(event_properties, '$.value') > '100'
ORDER BY event_timestamp DESC;

-- Example: Federated query across enterprise data sources
SELECT
    'enterprise_activity' as event_name,
    u.user_id,
    current_timestamp as event_timestamp,
    JSON_FORMAT(JSON_OBJECT(
        'crm_interactions', c.interaction_count,
        'warehouse_orders', w.order_count,
        'lake_analytics', l.score_value
    )) as event_properties
FROM salesforce_catalog.users.accounts u
LEFT JOIN crm_catalog.interactions.summary c ON u.user_id = c.user_id
LEFT JOIN warehouse_catalog.orders.summary w ON u.user_id = w.user_id
LEFT JOIN datalake_catalog.analytics.scores l ON u.user_id = l.user_id
WHERE u.created_date >= current_date - INTERVAL '30' DAY;