CASSANDRA + PIG integration

1.       Basic steps to make it work are

·         Install pig  from http://archanaschangale.wordpress.com/2013/10/14/pig-installation-on-ubuntu/

·         Set aall variables like this

o    for jar in $CASSANDRA_HOME/lib/*.jar; do CLASSPATH=$CLASSPATH:$jar; done;

o    export PIG_CLASSPATH=$PIG_CLASSPATH:$CLASSPATH;

o    export PIG_OPTS="$PIG_OPTS -Dudf.import.list=org.apache.cassandra.hadoop.pig";

o    export PIG_INITIAL_ADDRESS=localhost;

o    export PIG_RPC_PORT=9160;

o    export PIG_PARTITIONER=org.apache.cassandra.dht.RandomPartitioner;

o    pig

·         Run Pig –x local

o   Run  script to connect to Cassandra using cqlstorage().

o   STORE data_to_insert INTO 'cql://myschema/example?output_query=update+example+set+value1++%3D+%3F' USING CqlStorage(); - ENCODED

o   STORE data_to_insert INTO 'cql://myschema/example?output_query=update example set value1 @ #,value2 @ #' USING CqlStorage();  -UN ENCODED.