System коннектор#

System коннектор предоставляет информацию о кластере CedrusData.

Конфигурация#

Коннектор не требует конфигурации. Информация о кластере доступна по умолчанию в каталоге system.

Работа с System коннектором#

Получить список доступных схем:

SHOW SCHEMAS FROM system;

Получить список доступных таблиц для одной из схем:

SHOW TABLES FROM system.runtime;

Получить список узлов в кластере CedrusData:

SELECT * FROM system.runtime.nodes;

Остановить выполнение запроса по query ID:

CALL system.runtime.kill_query(query_id => '20151207_215727_00146_tx3nr', message => 'Using too many resources');

Таблицы System коннектора#

metadata.catalogs#

Содержит список доступных каталогов.

metadata.schema_properties#

Содержит список параметров, которые могут быть использованы при создании новой схемы.

metadata.table_properties#

Содержит список параметров, которые могут быть использованы при создании новой таблицы.

metadata.materialized_views#

Содержит информацию о материализованных представлениях.

Колонка

Описание

catalog_name

Имя каталога, которому принадлежит данное материализованное представление.

schema_name

Имя схемы в каталоге catalog_name, которой принадлежит данное материализованное представление.

name

Имя материализованного представления.

storage_catalog

Имя каталога, которому принадлежит таблица, хранящая данные материализованного представления.

storage_schema

Имя схемы в каталоге storage_catalog, которой принадлежит таблица, хранящая данные материализованного представления.

storage_table

Имя таблицы, которая хранит данные материализованного представления.

freshness

Актуальность данных в storage_table. Возможные состояния: FRESH, STALE, UNKNOWN. Если данные находятся в состоянии STALE, запрос будет перенаправлен в оригинальный источник данных. В противном случае данные будут прочитаны из материализованного представления.

owner

Имя пользователя, который создал материализованное представление.

comment

Комментарий.

definition

SQL-запрос, использованный для построения материализованного представления.

metadata.materialized_view_properties#

Содержит список параметров, которые могут быть использованы при создании нового материализованного представления.

metadata.table_comments#

Содержит комментарии к таблицам.

runtime.nodes#

Возвращает информацию об узлах кластера CedrusData.

runtime.optimizer_rule_stats#

Содержит статистики вызова правил оптимизации при планировании запроса.

runtime.queries#

Возвращает информацию о текущих и исполненных SQL-запросах в кластере CedrusData, включая имя пользователя, запустившего запрос, а так же информацию о профиле производительности запроса.

runtime.tasks#

Возвращает информацию об объектах task, использованных при выполнении запроса, включая идентификатор запроса и количество обработанных данных.

runtime.transactions#

Возвращает информацию о текущих транзакциях, включая время создания, параметры транзакции, и названия вовлеченных каталогов.

cedrusdata.license#

Содержит информацию о лицензии CedrusData в виде пар ключ-значение.

Колонка

Описание

name

Название свойства. Допустимые значения: type - тип лицензии (EVALUATION, DEVELOPMENT, FULL); owner - владелец лицензии; startDate - дата начала срока действия лицензии, endDate - дата окончания срока действия лицензии (не задано для EVALUATION); gracePeriodDays - длительность grace period в днях.

value

Значение свойства.

cedrusdata.stats_table_usage#

Отображает кумулятивную статистику о количестве данных, прочитанных из отдельных таблиц.

По умолчанию сбор статистики отключен. Для включения необходимо добавить параметр cedrusdata.stats.collect-table-usage=true в файл config.properties.

Процедура system.cedrusdata.clear_stats очищает собранную статистику.

Колонка

Описание

catalog_name

Имя каталога.

schema_name

Имя схемы.

table_name

Имя таблицы.

physical_input_bytes

Количество прочитанных данных таблицы в байтах.

physical_input_rows

Количество прочитанных строк таблицы.

cedrusdata.query_json#

Возвращает JSON-представление выполненных запросов. Данное представление можно использовать для последующего анализа производительности запроса с помощью функционала внешней истории.

Колонка

Описание

query_id

Уникальный идентификатор запроса.

info

JSON-представление запроса.

Процедуры System коннектора#

runtime.kill_query(query_id, message)#

Остановить выполнение запроса по query_id с заданным сообщением об ошибке. Параметр message является опциональным.

cedrusdata.clear_stats()#

Очищает статистику, отображаемую в таблице cedrusdata.stats_table_usage.

cedrusdata.refresh_query_external_history()#

Проанализировать директорию внешней истории запросов cedrusdata.query-external-history.path. После окончания анализа, исторические запросы из данной директории будут отображены в UI Trino.

Типы данных#

System коннектор содержит схемы со стандартными типами данных, которые не требуют дополнительных трансформаций.

Поддержка SQL команд#

Коннектор поддерживает общие команды и команды чтения данных.