Cassandra delta/relative querying

Question

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

---

Почему метаданные? Потому что с моей таблица выглядит как:

CREATE TABLE aTable (
    aTable_id timeuuid, 
    ... 
    PRIMARY KEY ((aTable_id)) 
) WITH 
... 

Я не могу поставить timeuuid ключа где положение как:

SELECT * FROM aTable WHERE aTable_id > minTimeuuid(?) 

и функция маркеров, даже если aTable_id правильно упорядоченные дать мне неправильные результаты:

SELECT * FROM aTable WHERE token(aTable_id) > token(minTimeuuid(?)) 

в общем, мой вопрос: как получить aTables новее, чем на определенную дату?

Answer 1

Так что я в конечном итоге с раствором, найденным в Meetup введения Cassandra 3.0.

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

Цель для меня было запрашивать только обновленную строку из предыдущей партии, и здесь, как я сделал:

• Создать таблицу индексов, распределяли по дате час (минуты, секунды и Миллис усечены). Эта таблица снабжается индексом gobal из основного стола.
• В java запросите индекс по часам (loop on a calendar) и выберите основную таблицу с запросом IN.
• Работа выполнена!

Answer 2

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

Вот пример, который близок к тому, что я делаю:

create table sensors(
    location varchar, 
    timestamp timeuuid, 
    ... 
    PRIMARY KEY(location, timestamp) 
) WITH CLUSTERING ORDER BY (timestamp DESC) AND ... 

Расположение является ключевым раздела и временной метки ключ кластеризации.

Затем вы можете выбрать, как это:

SELECT * from sensors 
    where location='tarifa' 
    and timestamp > maxTimeuuid('2015-04-15 13:00') 
    and timestamp < minTimeuuid('2015-04-15 15:00');