Re: How to use groupByKey and CqlPagingInputFormat

2014-07-05 Thread Martin Gammelsæter
e Datastax spark driver? > > Mohammed > > -Original Message- > From: Martin Gammelsæter [mailto:martingammelsae...@gmail.com] > Sent: Friday, July 4, 2014 12:43 AM > To: user@spark.apache.org > Subject: Re: How to use groupByKey and CqlPagingInputFormat > > On Th

RE: How to use groupByKey and CqlPagingInputFormat

2014-07-04 Thread Mohammed Guller
Datastax spark driver? Mohammed -Original Message- From: Martin Gammelsæter [mailto:martingammelsae...@gmail.com] Sent: Friday, July 4, 2014 12:43 AM To: user@spark.apache.org Subject: Re: How to use groupByKey and CqlPagingInputFormat On Thu, Jul 3, 2014 at 10:29 PM, Mohammed Guller

Re: How to use groupByKey and CqlPagingInputFormat

2014-07-04 Thread Martin Gammelsæter
On Thu, Jul 3, 2014 at 10:29 PM, Mohammed Guller wrote: > Martin, > > 1) The first map contains the columns in the primary key, which could be a > compound primary key containing multiple columns, and the second map > contains all the non-key columns. Ah, thank you, that makes sense. > 2) try

RE: How to use groupByKey and CqlPagingInputFormat

2014-07-03 Thread Mohammed Guller
Martin, 1) The first map contains the columns in the primary key, which could be a compound primary key containing multiple columns, and the second map contains all the non-key columns. 2) try this fixed code: val navnrevmap = casRdd.map{ case (key, value) => (ByteBufferUtil.s