¿Cómo recuperar solo la información que se cambió de Cassandra?

Estoy trabajando en el diseño del esquema de la Familia de columnas de Cassandra para mi caso de uso a continuación. No estoy seguro de cuál es la mejor manera de diseñar la familia de columnas de Cassandra para mi caso de uso a continuación. Usaré el controlador Java Datastax CQL para esto ..

A continuación se muestra mi caso de uso y el esquema de muestra que he diseñado por ahora:

SCHEMA_ID       RECORD_NAME               SCHEMA_VALUE              TIMESTAMP
1                  ABC                     some value                 t1
2                  ABC                     some_other_value           t2
3                  DEF                     some value again           t3
4                  DEF                     some other value           t4
5                  GHI                     some new value             t5
6                  IOP                     some values again          t6

Ahora, lo que miraré en la tabla de arriba es algo así:

Por primera vez, cuando mi aplicación se está ejecutando, pediré todo lo que aparece en la tabla de arriba. Lo que significa que me dan todo de la tabla de arriba.Luego, cada 5 o 10 minutos, mi hilo de fondo verificará esta tabla y solicitará que me den todo lo que ha cambiado solo (fila completa si algo se cambió para esa fila) .. así que esa es la razón por la que estoy usando la marca de tiempo como una de la columna aquí ..

Pero no estoy seguro de cómo diseñar el patrón de consulta de tal manera que mis dos casos de uso se satisfagan fácilmente y ¿cuál será la forma correcta de diseñar la tabla para esto? Aquí SCHEMA_ID será la clave principal que estoy pensando usar ...

Usaré CQL y el controlador de Java Datastax para esto ..

Actualizar:-

Si estoy usando algo como esto, ¿hay algún problema con este enfoque?

CREATE TABLE TEST (SCHEMA_ID TEXT, RECORD_NAME TEXT, SCHEMA_VALUE TEXT, LAST_MODIFIED_DATE TIMESTAMP, PRIMARY KEY (ID));

INSERT INTO TEST (SCHEMA_ID, RECORD_NAME, SCHEMA_VALUE, LAST_MODIFIED_DATE) VALUES ('1', 't26',  'SOME_VALUE', 1382655211694);

Porque, en este caso de uso, no quiero que nadie inserte lo mismo.SCHEMA_ID cada vez..SCHEMA_ID debería ser único cada vez que insertemos una nueva fila en esta tabla ... Entonces, con su ejemplo (@omnibear), podría ser posible, ¿alguien puede insertar el mismo SCHEMA_ID dos veces? ¿Estoy en lo correcto?

Y también con respecto atype ha tomado como una columna adicional, ese tipo de columna puede serrecord_name en mi ejemplo ..

Respuestas a la pregunta(1)

Su respuesta a la pregunta