--- metadata: - name: generator content: Diplodoc Platform v5.52.0 alternate: - https://ydb.tech/docs/en/yql/query_plans.md?version=v25.3 - https://ydb.tech/docs/ru/yql/query_plans.md?version=v25.3 - href: ru/yql/query_plans.md type: text/markdown title: Markdown version - href: ../llms.txt type: text/markdown title: llms.txt sourcePath: ru/core/yql/query_plans.md --- > **Documentation Index:** Fetch the complete configuration index at https://ydb.tech/docs/ru/llms.txt # Структура планов запросов Чтобы лучше понимать работу запроса, вы можете получить и проанализировать его план. Структура плана запроса в YDB представляет собой граф, где каждый узел содержит информацию об операциях и таблицах. Ниже представлена справочная информация по типам узлов, а пример анализа конкретного плана запроса можно посмотреть [здесь](https://ydb.tech/docs/ru/dev/query-plans-optimization.md?version=v25.3). ## Типы узлов ### Stage Стадия выполнения запроса. Визуальное представление: ![stage](_assets/stage.png) Стадия может содержать следующие операции: #### TableFullScan Полное сканирование таблицы. Важно иметь ввиду, что ресурсоёмкость данной операции пропорциональна размеру таблицы, поэтому по возможности ее стоит избегать. Атрибут | Значение --- | --- Table | имя таблицы ReadColumns | список читаемых колонок ReadLimit | лимит на число прочитанных строк Reverse | флаг, указывающий на порядок, в котором будут прочитаны строки, по умолчанию порядок прямой (от меньшего к большему), но в случае выставления флага в `true` порядок чтения будет обратным Parallel | флаг, указывающий на то что чтение строк будет происходить паралленьно по шардам #### TableRangeScan Чтение строк таблицы по определённому диапазону значений первичного ключа. Атрибут | Значение --- | --- Table | имя таблицы ReadColumns | список читаемых колонок ReadRange | диапазон ключей, по которому выполняется чтение ReadLimit | лимит на число прочитанных строк Reverse | флаг, указывающий на порядок, в котором будут прочитаны строки, по умолчанию порядок прямой (от меньшего к большему), но в случае выставления флага в `true` порядок чтения будет обратным Parallel | флаг, указывающий на то что чтение строк будет происходить паралленьно по шардам #### TablePointLookup {% note warning %} Поддерживается только для [строковых](https://ydb.tech/docs/ru/concepts/datamodel/table.md?version=v25.3#row-oriented-tables) таблиц. Поддержка функциональности для [колоночных](https://ydb.tech/docs/ru/concepts/datamodel/table.md?version=v25.3#column-oriented-tables) таблиц находится в разработке. {% endnote %} Чтение строк таблицы по конкретным значениям первичного ключа. Обратите внимание, что для этой операции необходимо указать все компоненты первичного ключа, чтение по префиксу ключа выполняется как `TableRangeScan`. Атрибут | Значение --- | --- Table | имя таблицы ReadColumns | список читаемых колонок #### Upsert Перезапись строк таблицы по соответствующим значениям первичного ключа, если они существовали, иначе добавление новых строк. Атрибут | Значение --- | --- Table | имя таблицы Columns | колонки, которые содержит строка #### Delete Удаление строк из таблицы. Атрибут | Значение --- | --- Table | имя таблицы #### Join Объединение двух таблиц, в описании операции указана используемая стратегия (JoinDict или MapJoin). - JoinDict - строятся словари для правой и левой частей, а затем выполняется их объединение по ключам - MapJoin - для каждого элемента из левой части выполняется поиск по ключу в предварительно построенном словаре для правой части #### Filter Фильтрация строк, в результате остаются только те строки, для которых предикат оказался true. Атрибут | Значение --- | --- Predicate | условие фильтрации Limit | лимит на число строк #### Aggregate Группировка строк по значениям колонок с построением агрегатов. Атрибут | Значение --- | --- GroupBy | колонки, по которым выполняется группировка Aggregation | агрегатные функции #### Sort Сортировка строк. Атрибут | Значение --- | --- SortBy | колонки, по которым выполняется сортировка #### TopSort Сортировка строк с применением лимита. Атрибут | Значение --- | --- TopSortBy | колонки, по которым выполняется сортировка Limit | лимит на число строк #### Top Взятие N элементов таким образом, что все они меньше или равны N+1 элемента, если бы вся последовательность была отсортирована. Атрибут | Значение --- | --- TopBy | колонки, по которым будут взяты первые N строк Limit | лимит на число строк #### Limit Ограничение на число строк. Атрибут | Значение --- | --- Limit | величина лимита #### Offset Смещение, позволяющее пропустить первые N элементов заданного набора строк. Атрибут | Значение --- | --- Offset | величина смещения #### Union Объединение результатов двух и более подзапросов в один набор. #### Iterator Итератор по заданному набору строк, как правило в качестве аргумента принимает [precompute](#precompute). #### PartitionByKey Партиционирование по ключу, как правило в качестве аргумента принимает [precompute](#precompute). ### Connection Зависимость по данным между стадиями. Визуальное представление: ![connection](_assets/connection.png) Каждая стадия исполняется в виде некоторого количества тасков. Например, читающая таблицу стадия может исполняться в N тасков, где N - это количество шардов таблицы. От того, какой connection используется, зависит как именно данные будут передаваться между стадиями. Далее будут описаны все возможные типы connection'ов, для их описания удобно ввести термины producer stage - стадия, отправляющая данные и consumer stage - стадия, принимающая данные. #### UnionAll Объединяет результаты всех тасков producer stage и отдаёт их как единый результат в единственный таск consumer stage. #### Merge Частный случай `UnionAll`, когда результаты producer stage отсортированы по заданному набору колонок, результат также отсортирован. #### Broadcast Рассылает результат единственного таска producer stage на все таски consumer stage. #### Map Реализует связи тасков стадий 1-к-1, то есть producer stage и consumer stage должны иметь одинаковое количество тасков. #### HashShuffle Рассылает результаты с тасков producer stage на таски consumer stage по некоторому правилу для заданных колонок. Правило жётско описано в коде, но вот список колонок указывается в каждом connection'е независимо. ### ResultSet Результат выполнения запроса, возвращаемый клиенту. Визуальное представление: ![resultset](_assets/resultset.png) ### Precompute Материализованный в памяти промежуточный результат. Визуальное представление: ![precompute](_assets/precompute.png) Cтадии, использующие precompute, начинают выполняться только после завершения вычисления precompute.