incubator-cassandra-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Michael Fortin <mi...@m410.us>
Subject Updating Cascal
Date Thu, 25 Nov 2010 16:14:43 GMT
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
Mime
View raw message