On Thu, Jul 3, 2014 at 10:29 PM, Mohammed Guller <[email protected]> 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 this fixed code:
> val navnrevmap = casRdd.map{
> case (key, value) =>
> (ByteBufferUtil.string(value.get("navn")),
> ByteBufferUtil.toInt(value.get("revisjon")))
> }.groupByKey()
I changed from CqlPagingInputFormat to the new Datastax
cassandra-spark driver, which is a bit easier to work with, but
thanks! I'm curious though, what is the semantic difference between
map({}) and map{}?
