Расширенное партицирование

Партицирование позволяет подсказать для YDB правила размещения данных в S3 (Yandex Object Storage).

Предположим, что данные в S3 (Yandex Object Storage) хранятся в следующей структуре каталогов:

year=2021
    month=01
    month=02
    month=03
year=2022
    month=01

При выполнении запроса ниже YDB выполнит следующие действия:

1. Получит полный список подкаталогов внутри '/'.
2. Для каждого подкаталога выполнит попытку обработать имя подкаталога в формате year=<DIGITS>.
3. Для каждого подкаталога year=<DIGITS> получит список всех подкаталогов в формате month=<DIGITS>.
4. Обработает считанные данные.

SELECT
    *
FROM
    objectstorage.'/'
WITH
(
    SCHEMA =
    (
        data String,
        year Int32,
        month Int32
    ),
    PARTITIONED_BY = "['year', 'month']"
)
WHERE
    year=2021
    AND month=02

То есть при работе с партицированными данными выполняется полный листинг содержимого S3 (Yandex Object Storage), что может занимать продолжительное время на бакетах большого размера.

Для оптимизации работы на больших объемах данных следует использовать "расширенное партицирование". В этом режиме не происходит сканирования каталогов S3 (Yandex Object Storage), вместо этого все пути вычисляются заранее и обращение происходит только к ним.

Для работы расширенного партицирования необходимо задать правила работы через специальный параметр - "projection". В этом параметре описываются все правила размещения данных в каталога S3 (Yandex Object Storage).

Синтаксис

Расширенное партицирование называется "partition projection" и задается через параметр projection.

Пример указания расширенного партицирования:

SELECT
    *
FROM
    <connection>.`/`
WITH
(
    SCHEMA =
    (
        data String,
        year Int32,
        month Int32
    ),
    PARTITIONED_BY = "['year', 'month']",
    `projection.enabled` : "true",

    `projection.year.type` : "integer",
    `projection.year.min` : "2010",
    `projection.year.max` : "2022",
    `projection.year.interval` : "1",

    `projection.month.type` : "integer",
    `projection.month.min` : "1",
    `projection.month.max` : "12",
    `projection.month.interval` : "1",
    `projection.month.digits` : "2",

    `storage.location.template` : "${year}/${month}"
)

В примере выше указывается, что данные существуют за каждый год и каждый месяц с 2010 по 2022 годы, при этом в бакете данные размещены в каталогах вида 2022/12. Если данные за какой-то период отсутствуют внутри бакета, то это не приводит к ошибкам, запрос выполнится успешно, а данные будут пропущены в расчетах.

В общем виде настройка расширенного партицирования выглядит следующим образом:

SELECT
    *
FROM
    <connection>.<path>
WITH
(
    SCHEMA = (<fields>, <field1>, <field2>),
    PARTITIONED_BY = "'['field1', 'field2']",
    `projection.enabled` : <"true"|"false">,

    `projection.<field1_name>.type` : "<type>",
    `projection.<field1_name>....` : "<extended_properties>",

    `projection.<field2_name>.type` : "<type>",
    `projection.<field2_name>....` : "<extended_properties>",

    `storage.location.template` : ".../${field2}/${field1}/..."

)

Описание полей

Поле типа integer

Используется для колонок, чьи значения можно представить в виде целых чисел диапазона 2^-63 до 2⁶³-1.

Поле типа enum

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

Поле типа date

Используется для колонок, чьи значения можно представить в виде даты. Допустимый диапазон дат с 1970-01-01 до 2105-01-01.

Работа с макроподстановкой NOW

1. Поддерживается ряд арифметических операция с макроподстановкой NOW: прибавление интервала времени и вычитание интервала времени. Например: NOW-3DAYS, NOW+1MONTH, NOW-6YEARS, NOW + 4HOURS, NOW - 5MINUTES, NOW + 6SECONDS. Возможные варианты использования макроподстановки описываются регулярным выражением: ^\s*(NOW)\s*(([\+\-])\s*([0-9]+)\s*(YEARS?|MONTHS?|WEEKS?|DAYS?|HOURS?|MINUTES?|SECONDS?)\s*)?$
2. Допустимые размерности интервалов: YEARS, MONTHS, WEEKS, DAYS, HOURS, MINUTES, SECONDS, MILLISECONDS.
3. В выражениях возможно использовать только одно арифметическое действие, выражения вида NOW-5MINUTES+6SECONDS не поддерживаются.
4. Работа с интервалами всегда приводит к получению корректной даты, но в зависимости от размерности, итоговые результаты могут быть разными:
   • При прибавлении MONTHS к дате происходит добавление календарного месяца, а не фиксированного числа дней. Например, если текущая дата - 2023-01-31, то прибавление 1 MONTHS приведет к получению даты 2023-02-28.
   • При прибавлении 30 DAYS к дате происходит добавление фиксированного числа дней. Например, если текущая дата - 2023-01-31, то прибавление 30 DAYS приведет к получению даты 2023-03-02.
   • Минимальная возможная дата - 1970-01-01 года (время 0 в Unix time). Если в результате вычислений возникает дата меньше минимальной, то весь запрос завершается с ошибкой.
   • Максимальная возможная дата - 2105-12-31 года (максимальная дата в Unix time). Если в результате вычислений возникает дата больше максимальной, то весь запрос завершается с ошибкой.

Шаблоны путей

Данные в бакетах S3 (Yandex Object Storage) могут быть размещены в каталогах с произвольными названиями. С помощью настройки storage.location.template можно указать правила именования каталогов, где хранятся данные.

Если в пути находится знак $, \ или знаки {}, то их необходимо экранировать с помощью символа \. Например, для работы с каталогом с именем my$folder необходимо указать путь следующим образом: my\$folder.