Можно ли заблокировать расщепление области в сопроцессоре hbase?

У меня есть некоторая обработка (обогащение сделок) в моем сервисе coprocesserService, который изменяет существующие данные на месте. Он перебирает каждую строку, модифицирует и возвращает ее в регион. Таблица может быть изменена только одним клиентом.

Во время обработки размер данных удваивается -> размер региона увеличивается -> происходит разделение региона. Это означает, что обработка прекращается по исключению NotServingRegionException (поскольку область закрыта и разделена на две новые области, поэтому она закрыта и больше не существует).

Есть ли какой-нибудь чистый способ заблокировать расщепление региона на время обработки?

У меня есть идея создать собственный RegionSplitPolicy и explicilty установить некоторый флаг, который будет возвращать ложь в shouldSplit(), но я пока не уверен, безопасно ли это.

Не могли бы вы посоветовать?

0 ответов

Другие вопросы по тегам