Composite primary keys

[hashbike]

trafficstars

Hello,

How do I define composite primary in the mapping curl request? Thanks in advance.

Following is my CF structure:

CREATE TABLE logs ( txn_id text, logged_at timestamp, des text, dump text, src text, PRIMARY KEY (txn_id, logged_at) )

Cheers

[srecon]

Hi, I am very busy with my project - i will let you know when will have find some time to check the issue.

[JBDuranceau-AUM]

Hi,

the primary key declaration should look like :

"primary_key" : "txn_id, logged_at"

I have a same like primary key and I succesfully succes to index my datas.

[eksenga]

Is there a way to ignore a specific column? I have a custom column that stores a custom data type. It would require some sort of custom mapping when pulling data from from Cassandra but would I prefer to ignore it for now.

The error thrown when the cron job runs:

015-03-10 20:20:01,080][ERROR][org.quartz.core.ErrorLogger] Job (river.RiveryookoreusersJob threw an exception.
org.quartz.SchedulerException: Job threw an unhandled exception. [See nested exception: com.datastax.driver.core.exceptions.InvalidTypeException: Column profile is of type 'org.apache.cassandra.db.marshal.UserType(yookore,70726f66696c655f74797065,626972746864617465:org.apache.cassandra.db.marshal.TimestampType,67656e646572:org.apache.cassandra.db.marshal.UTF8Type,7469746c65:org.apache.cassandra.db.marshal.UTF8Type,72656c6174696f6e73686970737461747573:org.apache.cassandra.db.marshal.UTF8Type,686f6d65636f756e747279:org.apache.cassandra.db.marshal.UTF8Type,63757272656e74636f756e747279:org.apache.cassandra.db.marshal.UTF8Type,74696d657a6f6e65:org.apache.cassandra.db.marshal.UTF8Type,70726f66696c6570696374757265:org.apache.cassandra.db.marshal.BytesType,616c7465726e6174655f656d61696c:org.apache.cassandra.db.marshal.UTF8Type,72656c6967696f6e:org.apache.cassandra.db.marshal.UTF8Type,696e74657265737473:org.apache.cassandra.db.marshal.ListType(org.apache.cassandra.db.marshal.UTF8Type),63656c6c70686f6e65:org.apache.cassandra.db.marshal.UTF8Type,62696f677261706879:org.apache.cassandra.db.marshal.UTF8Type)']
    at org.quartz.core.JobRunShell.run(JobRunShell.java:213)
    at org.quartz.simpl.SimpleThreadPool$WorkerThread.run(SimpleThreadPool.java:573)
Caused by: com.datastax.driver.core.exceptions.InvalidTypeException: Column profile is of type 'org.apache.cassandra.db.marshal.UserType(yookore,70726f66696c655f74797065,626972746864617465:org.apache.cassandra.db.marshal.TimestampType,67656e646572:org.apache.cassandra.db.marshal.UTF8Type,7469746c65:org.apache.cassandra.db.marshal.UTF8Type,72656c6174696f6e73686970737461747573:org.apache.cassandra.db.marshal.UTF8Type,686f6d65636f756e747279:org.apache.cassandra.db.marshal.UTF8Type,63757272656e74636f756e747279:org.apache.cassandra.db.marshal.UTF8Type,74696d657a6f6e65:org.apache.cassandra.db.marshal.UTF8Type,70726f66696c6570696374757265:org.apache.cassandra.db.marshal.BytesType,616c7465726e6174655f656d61696c:org.apache.cassandra.db.marshal.UTF8Type,72656c6967696f6e:org.apache.cassandra.db.marshal.UTF8Type,696e74657265737473:org.apache.cassandra.db.marshal.ListType(org.apache.cassandra.db.marshal.UTF8Type),63656c6c70686f6e65:org.apache.cassandra.db.marshal.UTF8Type,62696f677261706879:org.apache.cassandra.db.marshal.UTF8Type)'
    at com.datastax.driver.core.ColumnDefinitions.checkType(ColumnDefinitions.java:305)
    at com.datastax.driver.core.ArrayBackedRow.getString(ArrayBackedRow.java:167)
    at com.datastax.driver.core.ArrayBackedRow.getString(ArrayBackedRow.java:181)
    at com.blu.es.cassandra.CassandraFactory.getStringValue(CassandraFactory.java:168)
    at com.blu.es.cassandra.CassandraRiver$RiverJob.execute(CassandraRiver.java:301)
    at org.quartz.core.JobRunShell.run(JobRunShell.java:202)
    ... 1 more