http://www.datastax.com/support-forums/topic/question-with-integer-type-key-of-cassandra-different-from-where-i-inserted-by-java Software, Support, and Training for Apache Cassandra en-US Wed, 19 Jun 2013 04:50:18 +0000 http://bbpress.org/?v=1.0.3 q http://www.datastax.com/support-forums/search.php http://www.datastax.com/support-forums/topic/question-with-integer-type-key-of-cassandra-different-from-where-i-inserted-by-java#post-1388 Mon, 19 Mar 2012 09:26:13 +0000 Anonymous 1388@http://www.datastax.com/support-forums/ <p>Thanks a lot. Yes, I use thrift directly. Because it is faster than hector as we tested. </p> http://www.datastax.com/support-forums/topic/question-with-integer-type-key-of-cassandra-different-from-where-i-inserted-by-java#post-1140 Tue, 14 Feb 2012 20:32:03 +0000 nickmbailey 1140@http://www.datastax.com/support-forums/ <p>Are you just using thrift directly? You should almost certainly be using a high level client instead. See <a href="https://github.com/rantav/hector" rel="nofollow">https://github.com/rantav/hector</a> for a good java client.</p> <p>To answer your question, yes the problem is you are inserting the string "1" rather than the integer 1. In your example your java code would be something like:</p> <p>ByteBuffer b = ByteBuffer.allocate(4)<br /> b.putInt(4)<br /> client.insert(b.....) </p> http://www.datastax.com/support-forums/topic/question-with-integer-type-key-of-cassandra-different-from-where-i-inserted-by-java#post-1138 Tue, 14 Feb 2012 02:53:14 +0000 Anonymous 1138@http://www.datastax.com/support-forums/ <p>In short the key, get from console if different from which I wrote in Java.</p> <p>Detail:<br /> Schema of the CF:</p> <p>create column family books<br /> with column_type = 'Standard'<br /> and comparator = 'IntegerType'<br /> and default_validation_class = 'IntegerType'<br /> and key_validation_class = 'IntegerType'<br /> and rows_cached = 0.0<br /> and row_cache_save_period = 0<br /> and row_cache_keys_to_save = 2147483647<br /> and keys_cached = 200000.0<br /> and key_cache_save_period = 14400<br /> and read_repair_chance = 1.0<br /> and gc_grace = 864000<br /> and min_compaction_threshold = 4<br /> and max_compaction_threshold = 32<br /> and replicate_on_write = true<br /> and row_cache_provider = 'SerializingCacheProvider'<br /> and compaction_strategy = 'org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy';</p> <p>In Java I wrote:<br /> nameColumn.setTimestamp(System.currentTimeMillis());<br /> lastColumn.setTimestamp(System.currentTimeMillis());<br /> ageColumn.setTimestamp(System.currentTimeMillis());</p> <p>nameColumn.setValue(("fullName" + i).getBytes(UTF8));<br /> lastColumn.setValue(("address" + i).getBytes(UTF8));<br /> ageColumn.setValue(("password" + i).getBytes(UTF8));</p> <p>client.insert(ByteBuffer.wrap("1".getBytes(UTF8)),columnParent, lastColumn, ConsistencyLevel.ONE);<br /> client.insert(ByteBuffer.wrap("1".getBytes(UTF8)),columnParent, ageColumn, ConsistencyLevel.ONE);<br /> client.insert(ByteBuffer.wrap("1".getBytes(UTF8)),columnParent, nameColumn, ConsistencyLevel.ONE);</p> <p>And I get the result from command line:</p> <p>[default@twissandra] list books;<br /> Using default limit of 100<br /> -------------------<br /> RowKey: 49<br /> =&gt; (column=27413455319692147, value=7017844561841189680, timestamp=1329187533008)<br /> =&gt; (column=7382926377107942757, value=1890029152402194392368, timestamp=1329187533008)<br /> =&gt; (column=8097880544751088228, value=2073057419456278586416, timestamp=1329187533008)</p> <p>While the RowKey is 49? Because it is convert from String "1", how can I make the two value consistent? </p>