loads

loads предоставляет результаты задач загрузки. Это представление поддерживается начиная с Selena v1.5.2.

В loads предоставляются следующие поля:

Поле	Описание
ID	Глобально уникальный идентификатор.
LABEL	Метка задачи загрузки.
PROFILE_ID	ID профиля, который можно проанализировать через ANALYZE PROFILE.
DB_NAME	База данных, к которой принадлежит целевая таблица.
TABLE_NAME	Целевая таблица.
USER	Пользователь, который инициирует задачу загрузки.
WAREHOUSE	Warehouse, к которому принадлежит задача загрузки.
STATE	Состояние задачи загрузки. Допустимые значения: PENDING/BEGIN: Задача загрузки создана. QUEUEING/BEFORE_LOAD: Задача загрузки находится в очереди, ожидая планирования. LOADING: Задача загрузки выполняется. PREPARING: Транзакция находится в процессе предварительной фиксации. PREPARED: Транзакция предварительно зафиксирована. COMMITED: Транзакция зафиксирована. FINISHED: Задача загрузки завершена успешно. CANCELLED: Задача загрузки завершилась с ошибкой.
PROGRESS	Прогресс стадий ETL и LOADING задачи загрузки.
TYPE	Тип задачи загрузки. Для Broker Load возвращаемое значение - BROKER. Для INSERT возвращаемое значение - INSERT. Для Stream Load возвращаемое значение - STREAM. Для Routine Load возвращаемое значение - ROUTINE.
PRIORITY	Приоритет задачи загрузки. Допустимые значения: HIGHEST, HIGH, NORMAL, LOW и LOWEST.
SCAN_ROWS	Количество сканированных строк данных.
SCAN_BYTES	Количество сканированных байтов.
FILTERED_ROWS	Количество строк данных, отфильтрованных из-за недостаточного качества данных.
UNSELECTED_ROWS	Количество строк данных, отфильтрованных из-за условий, указанных в предложении WHERE.
SINK_ROWS	Количество загруженных строк данных.
RUNTIME_DETAILS	Метаданные выполнения загрузки. Подробности см. в RUNTIME_DETAILS.
CREATE_TIME	Время создания задачи загрузки. Формат: yyyy-MM-dd HH:mm:ss. Пример: 2023-07-24 14:58:58.
LOAD_START_TIME	Время начала стадии LOADING задачи загрузки. Формат: yyyy-MM-dd HH:mm:ss. Пример: 2023-07-24 14:58:58.
LOAD_COMMIT_TIME	Время фиксации транзакции загрузки. Формат: yyyy-MM-dd HH:mm:ss. Пример: 2023-07-24 14:58:58.
LOAD_FINISH_TIME	Время завершения стадии LOADING задачи загрузки. Формат: yyyy-MM-dd HH:mm:ss. Пример: 2023-07-24 14:58:58.
PROPERTIES	Статические свойства задачи загрузки. Подробности см. в PROPERTIES.
ERROR_MSG	Сообщение об ошибке задачи загрузки. Если задача загрузки не столкнулась с ошибкой, возвращается NULL.
TRACKING_SQL	SQL-запрос, который можно использовать для запроса журнала отслеживания задачи загрузки. SQL-запрос возвращается только тогда, когда задача загрузки включает некачественные строки данных. Если задача загрузки не включает некачественные строки данных, возвращается NULL.
REJECTED_RECORD_PATH	Путь, по которому вы можете получить доступ ко всем некачественным строкам данных, отфильтрованным в задаче загрузки. Количество зарегистрированных некачественных строк данных определяется параметром log_rejected_record_num, настроенным в задаче загрузки. Вы можете использовать команду wget для доступа к пути. Если задача загрузки не включает некачественные строки данных, возвращается NULL.

RUNTIME_DETAILS

• Универсальные метрики:

Метрика	Описание
load_id	Глобально уникальный ID плана выполнения загрузки.
txn_id	ID транзакции загрузки.

• Специфические метрики для Broker Load, INSERT INTO и Spark Load:

Метрика	Описание
etl_info	Детали ETL. Это поле действительно только для задач Spark Load. Для других типов задач загрузки значение будет пустым.
etl_start_time	Время начала стадии ETL задачи загрузки. Формат: yyyy-MM-dd HH:mm:ss. Пример: 2023-07-24 14:58:58.
etl_start_time	Время завершения стадии ETL задачи загрузки. Формат: yyyy-MM-dd HH:mm:ss. Пример: 2023-07-24 14:58:58.
unfinished_backends	Список BE с незавершенными выполнениями.
backends	Список BE, участвующих в выполнении.
file_num	Количество прочитанных файлов.
file_size	Общий размер прочитанных файлов.
task_num	Количество подзадач.

• Специфические метрики для Routine Load:

Метрика	Описание
schedule_interval	Интервал планирования Routine Load.
wait_slot_time	Время, прошедшее пока задача Routine Load ожидает слотов выполнения.
check_offset_time	Время, затраченное на проверку информации offset во время планирования задачи Routine Load.
consume_time	Время, затраченное задачей Routine Load на чтение исходных данных.
plan_time	Время генерации плана выполнения.
commit_publish_time	Время, затраченное на выполнение COMMIT RPC.

• Специфические метрики для Stream Load:

Метрика	Описание
timeout	Таймаут для задач загрузки.
begin_txn_ms	Время, затраченное на начало транзакции.
plan_time_ms	Время генерации плана выполнения.
receive_data_time_ms	Время получения данных.
commit_publish_time_ms	Время, затраченное на выполнение COMMIT RPC.
client_ip	IP-адрес клиента.

PROPERTIES

• Специфические свойства для Broker Load, INSERT INTO и Spark Load:

Свойство	Описание
timeout	Таймаут для задач загрузки.
max_filter_ratio	Максимальное соотношение строк данных, отфильтрованных из-за недостаточного качества данных.

• Специфические свойства для Routine Load:

Свойство	Описание
job_name	Имя задачи Routine Load.
task_num	Количество подзадач, фактически выполняемых параллельно.
timeout	Таймаут для задач загрузки.