It seems that CqlStorage can't perform INSERTs when using pig. IS there a reason for this?
Here's the relevant code from 2.0.7: String cqlQuery = CqlConfigHelper.getOutputCql(conf).trim(); if (cqlQuery.toLowerCase().startsWith("insert")) throw new UnsupportedOperationException("INSERT with CqlRecordWriter is not supported, please use UPDATE/DELETE statement"); … It seems to me that a DELETE and UPDATE is significantly less important than INSERT. My use case is that I'm using pig to build a custom secondary index, and then loading it back into cassandra. -- Founder/CEO Spinn3r.com Location: *San Francisco, CA* Skype: *burtonator* blog: http://burtonator.wordpress.com … or check out my Google+ profile<https://plus.google.com/102718274791889610666/posts> <http://spinn3r.com> War is peace. Freedom is slavery. Ignorance is strength. Corporations are people.