Pretty sure you are looking for something like: // thrift input job settings ConfigHelper.setInputRpcPort(job.getConfiguration(), "9160"); ConfigHelper.setInputInitialAddress(job.getConfiguration(), "127.0.0.1"); ConfigHelper.setInputPartitioner(job.getConfiguration(), "RandomPartitioner");
// thrift output job settings ConfigHelper.setOutputRpcPort(job.getConfiguration(), "9160"); ConfigHelper.setOutputInitialAddress(job.getConfiguration(), "127.0.0.1"); ConfigHelper.setOutputPartitioner(job.getConfiguration(), "RandomPartitioner"); From: Tejas Patil <tejas.patil...@gmail.com<mailto:tejas.patil...@gmail.com>> Reply-To: "user@cassandra.apache.org<mailto:user@cassandra.apache.org>" <user@cassandra.apache.org<mailto:user@cassandra.apache.org>> Date: Tuesday, January 29, 2013 4:29 PM To: "user@cassandra.apache.org<mailto:user@cassandra.apache.org>" <user@cassandra.apache.org<mailto:user@cassandra.apache.org>> Subject: Re: ConfigHelper.setThriftContact() undefined in cassandra v1.2 Hey Aaron, It gives compilation errors saying that the method is undefined. Thanks, Tejas Patil On Tue, Jan 29, 2013 at 4:17 PM, Edward Capriolo <edlinuxg...@gmail.com<mailto:edlinuxg...@gmail.com>> wrote: About as definitive as the word maybe. Oreilys seo keeps it close to top of search results but it probably not the think you want. On Tuesday, January 29, 2013, aaron morton <aa...@thelastpickle.com<mailto:aa...@thelastpickle.com>> wrote: > I am trying out the example given in Cassandra Definitive guide, Ch 12. > > That book may be out of date. > You might be better off with info from > http://www.datastax.com/docs/1.1/cluster_architecture/hadoop_integration and > http://wiki.apache.org/cassandra/HadoopSupport as well as the sample in the > source distribution. > > his statement gives error and I am not able to figure out the replacement for > it: > > What is the error? > Cheers > ----------------- > Aaron Morton > Freelance Cassandra Developer > New Zealand > @aaronmorton > http://www.thelastpickle.com > On 29/01/2013, at 9:37 PM, Tejas Patil > <tejas.patil...@gmail.com<mailto:tejas.patil...@gmail.com>> wrote: > > I am trying out the example given in Cassandra Definitive guide, Ch 12. This > statement gives error and I am not able to figure out the replacement for it: > ConfigHelper.setThriftContact(job.getConfiguration(), "localhost", 9160); > Also, > IColumn column = columns.get(columnName.getBytes()); > String value = new String(column.value()); > column.value() gives compilation error. any solutions ? > Thanks, > Tejas Patil >
