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 <[email protected]<mailto:[email protected]>> Reply-To: "[email protected]<mailto:[email protected]>" <[email protected]<mailto:[email protected]>> Date: Tuesday, January 29, 2013 4:29 PM To: "[email protected]<mailto:[email protected]>" <[email protected]<mailto:[email protected]>> 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 <[email protected]<mailto:[email protected]>> 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 <[email protected]<mailto:[email protected]>> 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 > <[email protected]<mailto:[email protected]>> 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 >
