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.