Как установить время ожидания и скорость регулирования для большого пользовательского совокупного запроса

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

Когда я получаю определенное количество строк в разделе, запрос начинает работать с ошибкой тайм-аута, поскольку, похоже, он использует фиксированное значение тайм-аута.

Но я не спешу, чтобы агрегированный запрос возвращал результаты, и я бы хотел, чтобы узел-координатор не торопился и агрегировал все строки без тайм-аута. Я также хотел бы ограничить скорость, с которой он просматривает результаты, чтобы не создавать чрезмерную нагрузку при агрегации.

Так есть ли способ установить время ожидания и скорость регулирования для запросов, выполнение которых, как ожидается, займет много времени?

Прямо сейчас я думаю, что единственный обходной путь - это разработать мою схему так, чтобы я оставлял свои разделы искусственно небольшими, чтобы агрегация была ниже фиксированного лимита времени ожидания.

Я использую базу альфа-кода Cassandra 3.0.

0 ответов

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