Skip to content

Instantly share code, notes, and snippets.

@a-chumagin
Created July 30, 2025 18:22
Show Gist options
  • Select an option

  • Save a-chumagin/c9ec0f27d60ca4b10032f0652a1bd034 to your computer and use it in GitHub Desktop.

Select an option

Save a-chumagin/c9ec0f27d60ca4b10032f0652a1bd034 to your computer and use it in GitHub Desktop.
CREATE OR REPLACE VIEW trino.completed_queries AS
SELECT
SUBSTRING_INDEX(`user`, '@', 1) AS usr,
`query`,
JSON_UNQUOTE(JSON_EXTRACT(inputs_json, '$[0].catalogName')) AS catalog,
JSON_UNQUOTE(JSON_EXTRACT(inputs_json, '$[0].schema')) AS `schema`,
`query_type`,
JSON_ARRAY(
JSON_OBJECT(
'catalogName', JSON_UNQUOTE(JSON_EXTRACT(inputs_json, '$[0].catalogName')),
'schema', JSON_UNQUOTE(JSON_EXTRACT(inputs_json, '$[0].schema')),
'table', JSON_UNQUOTE(JSON_EXTRACT(inputs_json, '$[0].table')),
'columns', JSON_ARRAY()
)
) AS accessed_metadata,
STR_TO_DATE(LEFT(`query_id`, 15), '%Y%m%d_%H%i%s') AS create_time,
DATE_ADD(
STR_TO_DATE(LEFT(`query_id`, 15), '%Y%m%d_%H%i%s'),
INTERVAL wall_time_millis / 1000 SECOND
) AS end_time,
`query_state`
FROM trino.trino_queries
WHERE
`query_state` = 'FINISHED'
AND `query_type` = 'SELECT'
AND inputs_json IS NOT NULL;
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment