Hello,
I forked Cascal (Scala based client for cassandra) and I'm attempting to
update it to cassandra 0.7. I have it partially working, but I'm getting stuck
on a few areas.
I have most of the unit tests working from the original code, but I'm having an
issue with batch_mutate(keyToFamilyMutations, consistency) . Does the log
output mean anything? I can't figure out why the columns are not getting
inserted. If I change th code from a batch_mutate to an insert(family, parent,
column, consistency) it works.
### keyToFamilyMutations: {java.nio.HeapByteBuffer[pos=0 lim=16
cap=16]={Standard=[Mutation(column_or_supercolumn:ColumnOrSuperColumn(column:Column(name:43
6F 6C 75 6D 6E 2D 61 2D 31, value:56 61 6C 75 65 2D 31,
timestamp:1290662894466035))),
Mutation(column_or_supercolumn:ColumnOrSuperColumn(column:Column(name:43 6F 6C
75 6D 6E 2D 61 2D 33, value:56 61 6C 75 65 2D 33,
timestamp:1290662894467942))),
Mutation(column_or_supercolumn:ColumnOrSuperColumn(column:Column(name:43 6F 6C
75 6D 6E 2D 61 2D 32, value:56 61 6C 75 65 2D 32,
timestamp:1290662894467915)))]}}
DEBUG 2010-11-25 00:28:14,534 [org.apache.cassandra.thrift.CassandraServer
pool-1-thread-2] batch_mutate
DEBUG 2010-11-25 00:28:14,583 [org.apache.cassandra.service.StorageProxy
pool-1-thread-2] insert writing local RowMutation(keyspace='Test',
key='ccfd5520f85411df858a001c42000009', modifications=[Standard])
DEBUG 2010-11-25 00:28:14,599 [org.apache.cassandra.thrift.CassandraServer
pool-1-thread-2] get_slice
DEBUG 2010-11-25 00:28:14,605 [org.apache.cassandra.service.StorageProxy
pool-1-thread-2] weakread reading SliceFromReadCommand(table='Test',
key='5374616e64617264', column_parent='QueryPath(columnFamilyName='Standard',
superColumnName='null', columnName='null')', start='', finish='',
reversed=false, count=2147483647) locally
DEBUG 2010-11-25 00:28:14,608 [org.apache.cassandra.service.StorageProxy
ReadStage:2] weakreadlocal reading SliceFromReadCommand(table='Test',
key='5374616e64617264', column_parent='QueryPath(columnFamilyName='Standard',
superColumnName='null', columnName='null')', start='', finish='',
reversed=false, count=2147483647)
### get_slice: []
The code looks like:
println("keyToFamilyMutations: %s".format(keyToFamilyMutations))
client.batch_mutate(keyToFamilyMutations, consistency)
…
client.client.get_slice(…)
keyspaces:
- name: Test
replica_placement_strategy: org.apache.cassandra.locator.SimpleStrategy
replication_factor: 1
column_families:
- {name: Standard, compare_with: BytesType}
Thanks,
Mike
