You need to set the property in your hadoop configuration: cassandra.consistencylevel.read to LOCAL_QUORUM.
All of the properties you can set are in the org.apache.cassandra.hadoop.ConfigHelper class. You can call that directly with Java/MapReduce or use the properties defined at the top in your hadoop configuration. See: For 0.7.6: http://svn.apache.org/repos/asf/cassandra/tags/cassandra-0.7.6-2/src/java/org/apache/cassandra/hadoop/ConfigHelper.java For 0.8.0: http://svn.apache.org/repos/asf/cassandra/tags/cassandra-0.8.0/src/java/org/apache/cassandra/hadoop/ConfigHelper.java (though they should be nearly identical) On Jun 13, 2011, at 11:20 PM, Badrinarayanan S wrote: > Hi, can anyone let me know the configuration steps required to read data > from Cassandra using PIG with consistency level of LOCAL_QUORUM. > > > > Thanks, > > badri >
