Re: Object mapper for CQL

[Kuldeep Mishra]

There is one High Level Java client for Cassandra which supports CQL is
Kundera.
You can find it here https://github.com/impetus-opensource/Kundera.

Other useful links are
https://github.com/impetus-opensource/Kundera/wiki/Getting-Started-in-5-minutes
https://github.com/impetus-opensource/Kundera/wiki/Object-mapper

How to use CQL
https://github.com/impetus-opensource/Kundera/wiki/Cassandra-Specific-Features

I hope it would help you.





On Sun, Jun 8, 2014 at 7:53 AM, Kevin Burton  wrote:

> Looks like the java-driver is working on an object mapper:
>
> "More modules including a simple object mapper will come shortly."
> But of course I need one now …
> I'm curious what others are doing here.
>
> I don't want to pass around Row objects in my code if I can avoid it..
> Ideally I would just run a query and get back a POJO.
>
> Another issue is how are these POJOs generated.  Are they generated from
> the schema?  is the schema generated from the POJOs ?  From a side file?
>
> And granted, there are existing ORMs out there but I don't think any
> support CQL.
>
> --
>
> Founder/CEO Spinn3r.com
> Location: *San Francisco, CA*
> Skype: *burtonator*
> blog: http://burtonator.wordpress.com
> … or check out my Google+ profile
> 
> 
> War is peace. Freedom is slavery. Ignorance is strength. Corporations are
> people.
>
>


-- 
Thanks and Regards
Kuldeep Kumar Mishra
+919540965199

Re: Added extra column as composite key while creation counter column family

[Kuldeep Mishra]

cassandra 1.2.0

Is it a bug in  1.2.0 ?


Thanks
KK


On Wed, Apr 17, 2013 at 2:56 AM, aaron morton wrote:

> What version are you using ?
>
> WIth 1.2.4 …
>
> cqlsh:dev>  CREATE TABLE counters (
>...   key text,
>...   value counter,
>...   PRIMARY KEY (key)
>...  ) WITH COMPACT STORAGE;
> cqlsh:dev> describe table counters;
>
> CREATE TABLE counters (
>   key text PRIMARY KEY,
>   value counter
> ) WITH COMPACT STORAGE AND
>   bloom_filter_fp_chance=0.01 AND
>   caching='KEYS_ONLY' AND
>   comment='' AND
>   dclocal_read_repair_chance=0.00 AND
>   gc_grace_seconds=864000 AND
>   read_repair_chance=0.10 AND
>   replicate_on_write='true' AND
>   populate_io_cache_on_flush='false' AND
>   compaction={'class': 'SizeTieredCompactionStrategy'} AND
>   compression={'sstable_compression': 'SnappyCompressor'};
>
> Cheers
>
> -
> Aaron Morton
> Freelance Cassandra Consultant
> New Zealand
>
> @aaronmorton
> http://www.thelastpickle.com
>
> On 15/04/2013, at 3:58 PM, Kuldeep Mishra 
> wrote:
>
> > Hi,
> >While I creating counter column family a extra column is being added
> what I do ?
> > Table creation script
> >  CREATE TABLE counters (
> >   key text,
> >   value counter,
> >   PRIMARY KEY (key)
> >  ) WITH COMPACT STORAGE
> >
> > after describing column family I am getting following
> > CREATE TABLE counters (
> >   key text,
> >   column1 text,
> >   value counter,
> >   PRIMARY KEY (key, column1)
> > ) WITH COMPACT STORAGE AND
> >   bloom_filter_fp_chance=0.01 AND
> >   caching='KEYS_ONLY' AND
> >   comment='' AND
> >   dclocal_read_repair_chance=0.00 AND
> >   gc_grace_seconds=864000 AND
> >   read_repair_chance=0.10 AND
> >   replicate_on_write='true' AND
> >   compaction={'class': 'SizeTieredCompactionStrategy'} AND
> >   compression={'sstable_compression': 'SnappyCompressor'};
> >
> > extra column column1 is added
> >
> > Please help
> >
> > --
> > Thanks and Regards
> > Kuldeep Kumar Mishra
> > +919540965199
>
>


-- 
Thanks and Regards
Kuldeep Kumar Mishra
+919540965199

Added extra column as composite key while creation counter column family

[Kuldeep Mishra]

Hi,
   While I creating counter column family a extra column is being added
what I do ?
Table creation script
 CREATE TABLE counters (
  key text,
  value counter,
  PRIMARY KEY (key)
 ) WITH COMPACT STORAGE

after describing column family I am getting following
CREATE TABLE counters (
  key text,
 * column1 text,*
  value counter,
  PRIMARY KEY (key,* column1*)
) WITH COMPACT STORAGE AND
  bloom_filter_fp_chance=0.01 AND
  caching='KEYS_ONLY' AND
  comment='' AND
  dclocal_read_repair_chance=0.00 AND
  gc_grace_seconds=864000 AND
  read_repair_chance=0.10 AND
  replicate_on_write='true' AND
  compaction={'class': 'SizeTieredCompactionStrategy'} AND
  compression={'sstable_compression': 'SnappyCompressor'};

extra column column1 is added

Please help

-- 
Thanks and Regards
Kuldeep Kumar Mishra
+919540965199

Re: Getting NullPointerException while executing query

[Kuldeep Mishra]

I am using cassandra 1.2.0,


Thanks
Kuldeep


On Wed, Apr 10, 2013 at 10:40 PM, Sylvain Lebresne wrote:

> On which version of Cassandra are you? I can't reproduce the
> NullPointerException on Cassandra 1.2.3.
>
> That being said, that query is not valid, so you will get an error
> message. There is 2 reasons why it's not valid:
>   1) in token(deep), deep is not a valid term. So you should have
> something like: token('deep').
>   2) the name column is not the partition key so the token method cannot
> be applied to it.
>
> A valid query with that schema would be for instance:
>   select * from "CQLUSER" where token(id) > token(4)
> though I don't know if that help in any way for what you aimed to do.
>
> --
> Sylvain
>
>
> On Wed, Apr 10, 2013 at 9:42 AM, Kuldeep Mishra 
> wrote:
>
>> Hi ,
>>  TABLE -
>> CREATE TABLE "CQLUSER" (
>>   id int PRIMARY KEY,
>>   age int,
>>   name text
>> )
>> Query -
>>   select * from "CQLUSER" where token(name) > token(deep);
>>
>> ERROR -
>> Bad Request: Failed parsing statement: [select * from "CQLUSER" where
>> token(name) > token(deep);] reason: NullPointerException null
>> text could not be lexed at line 1, char 15
>>
>> --
>> Thanks and Regards
>> Kuldeep Kumar Mishra
>> +919540965199
>>
>
>


-- 
Thanks and Regards
Kuldeep Kumar Mishra
+919540965199

Getting NullPointerException while executing query

[Kuldeep Mishra]

Hi ,
 TABLE -
CREATE TABLE "CQLUSER" (
  id int PRIMARY KEY,
  age int,
  name text
)
Query -
  select * from "CQLUSER" where token(name) > token(deep);

ERROR -
Bad Request: Failed parsing statement: [select * from "CQLUSER" where
token(name) > token(deep);] reason: NullPointerException null
text could not be lexed at line 1, char 15

-- 
Thanks and Regards
Kuldeep Kumar Mishra
+919540965199

describe keyspace or column family query not working

[Kuldeep Mishra]

Hi ,
I am trying to execute following query but not working and throwing
exception

QUERY:--
 Cassandra.Client client;
 client.execute_cql3_query(ByteBuffer.wrap("describe keyspace
mykeyspace".getBytes(Constants.CHARSET_UTF8)),   Compression.NONE,
ConsistencyLevel.ONE);

 client.execute_cql3_query(ByteBuffer.wrap("describe table
mytable".getBytes(Constants.CHARSET_UTF8)),   Compression.NONE,
ConsistencyLevel.ONE);

but both query giving following exception,

STACK TRACE

InvalidRequestException(why:line 1:0 no viable alternative at input
'describe')
at
org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result.read(Cassandra.java:37849)
at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)
at
org.apache.cassandra.thrift.Cassandra$Client.recv_execute_cql3_query(Cassandra.java:1562)
at
org.apache.cassandra.thrift.Cassandra$Client.execute_cql3_query(Cassandra.java:1547)

Please help..


Thanks and Regards
Kuldeep






-- 
Thanks and Regards
Kuldeep Kumar Mishra
+919540965199

Re: cql query not giving any result.

[Kuldeep Mishra]

Hi Sylvain,
  I created it using thrift client, here is column family creation
script,

Cassandra.Client client;
CfDef user_Def = new CfDef();
user_Def.name = "DOCTOR";
user_Def.keyspace = "KunderaExamples";
user_Def.setComparator_type("UTF8Type");
user_Def.setDefault_validation_class("UTF8Type");
user_Def.setKey_validation_class("UTF8Type");
ColumnDef key = new ColumnDef(ByteBuffer.wrap("KEY".getBytes()),
"UTF8Type");
key.index_type = IndexType.KEYS;
ColumnDef age = new ColumnDef(ByteBuffer.wrap("AGE".getBytes()),
"UTF8Type");
age.index_type = IndexType.KEYS;
user_Def.addToColumn_metadata(key);
user_Def.addToColumn_metadata(age);

client.set_keyspace("KunderaExamples");
client.system_add_column_family(user_Def);


Thanks
KK

On Fri, Mar 15, 2013 at 4:24 PM, Sylvain Lebresne wrote:

> On Fri, Mar 15, 2013 at 11:43 AM, Kuldeep Mishra  > wrote:
>
>> Hi,
>> Is it possible in Cassandra to make multiple column with same name ?,
>> like in this particular scenario I have two column with same name as "key",
>> first one is rowkey and second on is column name .
>>
>>
> No, it shouldn't be possible and that is your problem. How did you created
> that table?
>
> --
> Sylvain
>
>
>>
>> Thanks and Regards
>> Kuldeep
>>
>>
>> On Fri, Mar 15, 2013 at 4:05 PM, Kuldeep Mishra > > wrote:
>>
>>>
>>> Hi ,
>>> Following cql query not returning any result
>>> cqlsh:KunderaExamples> select * from "DOCTOR" where key='kuldeep';
>>>
>>>I have enabled secondary indexes on both column.
>>>
>>> Screen shot is attached
>>>
>>> Please help
>>>
>>>
>>> --
>>> Thanks and Regards
>>> Kuldeep Kumar Mishra
>>> +919540965199
>>>
>>
>>
>>
>> --
>> Thanks and Regards
>> Kuldeep Kumar Mishra
>> +919540965199
>>
>
>


-- 
Thanks and Regards
Kuldeep Kumar Mishra
+919540965199

Re: cql query not giving any result.

[Kuldeep Mishra]

Hi,
Is it possible in Cassandra to make multiple column with same name ?, like
in this particular scenario I have two column with same name as "key",
first one is rowkey and second on is column name .


Thanks and Regards
Kuldeep

On Fri, Mar 15, 2013 at 4:05 PM, Kuldeep Mishra wrote:

>
> Hi ,
> Following cql query not returning any result
> cqlsh:KunderaExamples> select * from "DOCTOR" where key='kuldeep';
>
>I have enabled secondary indexes on both column.
>
> Screen shot is attached
>
> Please help
>
>
> --
> Thanks and Regards
> Kuldeep Kumar Mishra
> +919540965199
>



-- 
Thanks and Regards
Kuldeep Kumar Mishra
+919540965199

Re: getting error for decimal type data

[Kuldeep Mishra]

ColumnFamily: STUDENT
  Key Validation Class: org.apache.cassandra.db.marshal.LongType
  Default column value validator:
org.apache.cassandra.db.marshal.BytesType
  Columns sorted by: org.apache.cassandra.db.marshal.UTF8Type
  GC grace seconds: 864000
  Compaction min/max thresholds: 4/32
  Read repair chance: 0.1
  DC Local Read repair chance: 0.0
  Replicate on write: true
  Caching: KEYS_ONLY
  Bloom Filter FP chance: default
  Built indexes: [STUDENT.STUDENT_AGE_idx,
STUDENT.STUDENT_BIG_DECIMAL_idx, STUDENT.STUDENT_PERCENTAGE_idx,
STUDENT.STUDENT_ROLL_NUMBER_idx, STUDENT.STUDENT_SEMESTER_idx,
STUDENT.STUDENT_STUDENT_NAME_idx, STUDENT.STUDENT_UNIQUE_ID_idx]
  Column Metadata:
Column Name: PERCENTAGE
  Validation Class: org.apache.cassandra.db.marshal.FloatType
  Index Name: STUDENT_PERCENTAGE_idx
  Index Type: KEYS
Column Name: AGE
  Validation Class: org.apache.cassandra.db.marshal.IntegerType
  Index Name: STUDENT_AGE_idx
  Index Type: KEYS
Column Name: SEMESTER
  Validation Class: org.apache.cassandra.db.marshal.UTF8Type
  Index Name: STUDENT_SEMESTER_idx
  Index Type: KEYS
Column Name: ROLL_NUMBER
  Validation Class: org.apache.cassandra.db.marshal.LongType
  Index Name: STUDENT_ROLL_NUMBER_idx
  Index Type: KEYS
Column Name: UNIQUE_ID
  Validation Class: org.apache.cassandra.db.marshal.LongType
  Index Name: STUDENT_UNIQUE_ID_idx
  Index Type: KEYS
Column Name: STUDENT_NAME
  Validation Class: org.apache.cassandra.db.marshal.UTF8Type
  Index Name: STUDENT_STUDENT_NAME_idx
  Index Type: KEYS
*Column Name: BIG_DECIMAL
  Validation Class: org.apache.cassandra.db.marshal.DecimalType
  Index Name: STUDENT_BIG_DECIMAL_idx
  Index Type: KEYS*
  Compaction Strategy:
org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy
  Compression Options:
sstable_compression:
org.apache.cassandra.io.compress.SnappyCompressor


for value of *BIG_DECIMAL is *2.28542855225E-825373481



Thanks
Kuldeep

On Tue, Jan 29, 2013 at 1:52 PM, Rishabh Agrawal <
rishabh.agra...@impetus.co.in> wrote:

>  Can you provide specs of the column family using describe.
>
>
>
> *From:* Kuldeep Mishra [mailto:kuld.cs.mis...@gmail.com]
> *Sent:* Tuesday, January 29, 2013 12:37 PM
> *To:* user@cassandra.apache.org
> *Subject:* getting error for decimal type data
>
>
>
> while I an trying to list column family data using cassandra-cli then I am
> getting following problem for decimal type data,
> any suggestion will be appreciated.
>
> Exception in thread "main" java.lang.OutOfMemoryError: Java heap space
> at
> java.lang.AbstractStringBuilder.(AbstractStringBuilder.java:45)
> at java.lang.StringBuilder.(StringBuilder.java:80)
> at java.math.BigDecimal.getValueString(BigDecimal.java:2885)
> at java.math.BigDecimal.toPlainString(BigDecimal.java:2869)
> at
> org.apache.cassandra.cql.jdbc.JdbcDecimal.getString(JdbcDecimal.java:72)
> at
> org.apache.cassandra.db.marshal.DecimalType.getString(DecimalType.java:62)
> at
> org.apache.cassandra.cli.CliClient.printSliceList(CliClient.java:2873)
> at org.apache.cassandra.cli.CliClient.executeList(CliClient.java:1486)
> at
> org.apache.cassandra.cli.CliClient.executeCLIStatement(CliClient.java:272)
> at
> org.apache.cassandra.cli.CliMain.processStatementInteractive(CliMain.java:210)
> at org.apache.cassandra.cli.CliMain.main(CliMain.java:337)
>
>
> --
> Thanks and Regards
> Kuldeep Kumar Mishra
> +919540965199
>
> --
>
>
>
>
>
>
> NOTE: This message may contain information that is confidential,
> proprietary, privileged or otherwise protected by law. The message is
> intended solely for the named addressee. If received in error, please
> destroy and notify the sender. Any use of this email is prohibited when
> received in error. Impetus does not represent, warrant and/or guarantee,
> that the integrity of this communication has been maintained nor that the
> communication is free of errors, virus, interception or interference.
>



-- 
Thanks and Regards
Kuldeep Kumar Mishra
+919540965199

getting error for decimal type data

[Kuldeep Mishra]

while I an trying to list column family data using cassandra-cli then I am
getting following problem for decimal type data,
any suggestion will be appreciated.

Exception in thread "main" java.lang.OutOfMemoryError: Java heap space
at java.lang.AbstractStringBuilder.(AbstractStringBuilder.java:45)
at java.lang.StringBuilder.(StringBuilder.java:80)
at java.math.BigDecimal.getValueString(BigDecimal.java:2885)
at java.math.BigDecimal.toPlainString(BigDecimal.java:2869)
at
org.apache.cassandra.cql.jdbc.JdbcDecimal.getString(JdbcDecimal.java:72)
at
org.apache.cassandra.db.marshal.DecimalType.getString(DecimalType.java:62)
at
org.apache.cassandra.cli.CliClient.printSliceList(CliClient.java:2873)
at org.apache.cassandra.cli.CliClient.executeList(CliClient.java:1486)
at
org.apache.cassandra.cli.CliClient.executeCLIStatement(CliClient.java:272)
at
org.apache.cassandra.cli.CliMain.processStatementInteractive(CliMain.java:210)
at org.apache.cassandra.cli.CliMain.main(CliMain.java:337)


-- 
Thanks and Regards
Kuldeep Kumar Mishra
+919540965199

Re: error when creating column family using cql3 and persisting data using thrift

[Kuldeep Mishra]

Hi Aaron,
I am using thrift client.

Here is column family creation script:-
```
String colFamily = "CREATE COLUMNFAMILY users (key varchar
PRIMARY   KEY,full_name varchar, birth_date int,state varchar)";
 conn.execute_cql3_query(ByteBuffer.wrap(colFamily.getBytes()),
Compression.NONE, ConsistencyLevel.ONE);
``

and thrift operation code :-

```
Cassandra.Client conn

 Map>> mutationMap = new
HashMap>>();

List insertion_list = new ArrayList();

  Mutation mut = new Mutation();
  Column column = new Column(ByteBuffer.wrap("full_name".getBytes()));
  column.setValue(ByteBuffer.wrap("emp".getBytes()));
  mut.setColumn_or_supercolumn(new ColumnOrSuperColumn().setColumn(column));
insertion_list.add(mut);

   Map> columnFamilyValues = new HashMap>();
   columnFamilyValues.put("users", insertion_list);

   mutationMap.put(ByteBuffer.wrap("K".getBytes()), columnFamilyValues);

   conn.batch_mutate(mutationMap, ConsistencyLevel.ONE);
``

and error stack trace :-
``
InvalidRequestException(why:Not enough bytes to read value of component 0)
at
org.apache.cassandra.thrift.Cassandra$batch_mutate_result.read(Cassandra.java:20833)
at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)
at
org.apache.cassandra.thrift.Cassandra$Client.recv_batch_mutate(Cassandra.java:964)
at
org.apache.cassandra.thrift.Cassandra$Client.batch_mutate(Cassandra.java:950)
````````


Thanks
Kuldeep Mishra

On Thu, Jan 17, 2013 at 8:40 AM, aaron morton wrote:

> The thrift request is not sending a composite type where it should. CQL 3
> uses composites in a lot of places.
>
> What was your table definition?
>
> Are you using a high level client or rolling your own?
>
> Cheers
>
> -
> Aaron Morton
> Freelance Cassandra Developer
> New Zealand
>
> @aaronmorton
> http://www.thelastpickle.com
>
> On 16/01/2013, at 5:32 AM, James Schappet  wrote:
>
> I also saw this while testing the
> https://github.com/boneill42/naughty-or-nice example project.
>
>
>
>
> --Jimmy
>
>
> From: Kuldeep Mishra 
> Reply-To: 
> Date: Tuesday, January 15, 2013 10:29 AM
> To: 
> Subject: error when creating column family using cql3 and persisting data
> using thrift
>
> Hi,
> I am facing following problem, when creating column family using cql3 and
> trying to persist data using thrift 1.2.0
> in cassandra-1.2.0.
>
> Details:
> InvalidRequestException(why:Not enough bytes to read value of component 0)
> at
> org.apache.cassandra.thrift.Cassandra$batch_mutate_result.read(Cassandra.java:20833)
> at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)
> at
> org.apache.cassandra.thrift.Cassandra$Client.recv_batch_mutate(Cassandra.java:964)
> at
> org.apache.cassandra.thrift.Cassandra$Client.batch_mutate(Cassandra.java:950)
> at
> com.impetus.client.cassandra.thrift.ThriftClient.onPersist(ThriftClient.java:157)
>
>
>
> Please help me.
>
>
> --
> Thanks and Regards
> Kuldeep Kumar Mishra
> +919540965199
>
>
>


-- 
Thanks and Regards
Kuldeep Kumar Mishra
+919540965199