Есть ли способ фильтрации столбца счетчика в кассандре?

Question

я не смог расшифровать о том, как приступить к прецеденту ....

Я хочу, чтобы количество некоторых элементов, и запрашивать данные таким образом, что

counter_value < threshold value 

Сейчас в Кассандре, индексы не могут быть сделаны на счетчиках, это то, что является проблемой, есть ли временное моделирование, которое можно сделать для достижения чего-то подобного?

благодарит

Answer 1

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

Если вы хотите запросить значение счетчика, это не может быть тип счетчика. Поскольку он не соответствует двум условиям, необходимых для запроса данных

1. не может быть частью индекса
2. не может быть частью раздела ключа

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

Так что, если вы хотите, чтобы решить эту проблему с помощью Кассандры, измените тип на длинный в Кассандре, сделать его кластеризации ключом или сделать индекс над этой колонкой. В любом случае это замедлит ваши записи и увеличит латентность каждой операции обновления значения счетчика, так как вы будете использовать anti parttern of read-before-write.

Я бы порекомендовал использовать индекс .

Последнее, но не менее важное: я рассмотрел бы использование базы данных SQL для этой проблемы.

Answer 2

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

См. Некоторые примеры here и here.

Другие подходы состоят в том, чтобы фильтровать возвращенные строки на стороне клиента или загружать данные в Spark и фильтровать строки в Spark.