Функция табличного процесса icebergCluster

Это расширение функции табличного процесса iceberg.

Позволяет обрабатывать файлы из Apache Iceberg параллельно с многих узлов в указанном кластере. На инициаторе устанавливается соединение со всеми узлами в кластере и динамически распределяются все файлы. На рабочем узле он запрашивает у инициатора следующую задачу для обработки и выполняет ее. Это повторяется, пока все задачи не будут завершены.

Синтаксис

Аргументы

cluster_name — Имя кластера, которое используется для построения набора адресов и параметров соединения с удаленными и локальными серверами.
Описание всех остальных аргументов совпадает с описанием аргументов в эквивалентной функции табличного процесса iceberg.

Возвращаемое значение

Таблица с указанной структурой для чтения данных из кластера в указанной таблице Iceberg.

Примеры

Смотрите также