pull @ https://github.com/alexliu68/cassandra/pull/3
Use CassandraStorage for any cql3 tables, you will have composite columns in "columns" bag
Use CqlStorage for any cql3 table.
page_size is the number of cql3 rows per page (the default is 1000, it's optional)
columns is the column names for the cql3 select query, it's optional
where_clause is the user defined where clause on the indexed column, it's optional
split_size is the number of C* rows per split which can be used to tune the number of mappers
output_query is the prepared query for inserting data to cql3 table (replace the = by @ and ? by #,
because Pig can't take = and ? as url parameter values)
Output row are in the following format
(((name, value), (name, value)), (value ... value), (value...value))
where the name and value tuples are key name and value pairs.
The input schema: ((name, value), (name, value), (name, value)) where keys are in the front.