Как включить основанный на времени сброс в класс пакетной мутации happybase?
Я использую python happybase для подключения к моему комиссионному серверу hbase. Он имеет класс пакетной мутации, который поддерживает размер пакета. Что мне действительно нужно, так это настройка временного интервала, чтобы я мог настроить мой сброс в зависимости от размера партии и времени, которое наступит раньше.
например, batch_size = 1000, time_interval=250
Таким образом, либо после 250 миллисекунд или 1000 событий batch.send() должен выполняться.
Я новичок в Python, но так как оригинальное приложение написано на Python, я пытаюсь понять, как этого добиться.