ROLLBACK DELTA

Содержание раздела

1. Число попыток отката дельты
2. Действия перед запросом
3. Синтаксис
4. Варианты ответа
5. Ограничения
6. Пример

Поддерживается в версиях: 7.2 / 7.1 / 7.0 / 6.12 / 6.11 / 6.10 / 6.9 / 6.8 / 6.7 / 6.6 / 6.5 / 6.4 / 6.3 / 6.2 / 6.1 / 6.0 / 5.8 / 5.7 / 5.6 / 5.5 / 5.4 / 5.3 / 5.2 / 5.1 / 5.0.

После запуска запроса дельту будет невозможно закрыть.

Запрос откатывает открытую дельту и отменяет внесенные в ней изменения. Если дельту не удалось откатить, система повторяет попытки:

• до успешного завершения отката — по умолчанию;
• до исчерпания попыток — если их число ограничено конфигурацией.

При успешном выполнении запроса дельта удаляется из сервисной БД и ее номер освобождается для следующей дельты. Номера операций записи, выполненных ранее в этой дельте, НЕ освобождаются.

Откат дельты управляется настройками, заданными в секции конфигурации core.delta.

Число попыток отката дельты

По умолчанию система повторяет попытки отката дельты до ее успешного отката. Ограничить число попыток можно параметром DELTA_ROLLBACK_RETRY_COUNT. Если дельту не удалось откатить за заданное количество попыток, запрос завершается с ошибкой.

Действия перед запросом

Перед выполнением запроса выберите логическую базу данных, используемую по умолчанию, если она еще не выбрана.

Синтаксис

ROLLBACK DELTA

Варианты ответа

В ответе возвращается:

• объект ResultSet c одной записью, содержащей номер отмененной дельты, при успешном выполнении запроса;
• исключение при неуспешном выполнении запроса.

Ограничения

• Выполнение запроса недоступно, если выполняется ERASE DELTA.
• Во время работы запроса недоступны:
  • выполнение ERASE DELTA,
  • загрузка и обновление данных.
• После запуска запроса дельту невозможно закрыть.
• Запрос не отменяет операции записи, выполненные до дельты.
• При обработке запроса неактивные датасорсы пропускаются без возврата ошибки. Ошибка возвращается, если не осталось ни одного активного датасорса, подходящего для исполнения запроса.
• Если во время неактивности некоторых датасорсов данные были загружены из Kafka и затем отменены запросом ROLLBACK DELTA, перед следующей загрузкой из того же топика необходимо выровнять прочитанные смещения для всех консьюмер-групп, например командой TOPIC_RESET.

Пример

USE marketing;
ROLLBACK DELTA;