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
) => (ByteBufferUtil.string(value.get("navn")), ByteBufferUtil.toInt(value.get("revisjon"))) }.groupByKey() Mohammed -Original Message- From: Martin Gammelsæter [mailto:martingammelsae...@gmail.com] Sent: Wednesday, July 2, 2014 4:36 AM To: user@spark.apache.

How to use groupByKey and CqlPagingInputFormat

2014-07-02 Thread Martin Gammelsæter
Hi! Total Scala and Spark noob here with a few questions. I am trying to modify a few of the examples in the spark repo to fit my needs, but running into a few problems. I am making an RDD from Cassandra, which I've finally gotten to work, and trying to do some operations on it. Specifically I a