Dear Wiki user, You have subscribed to a wiki page or wiki category on "Cassandra Wiki" for change notification.
The "ScribeToCassandra" page has been changed by mck. http://wiki.apache.org/cassandra/ScribeToCassandra?action=diff&rev1=3&rev2=4 -------------------------------------------------- } }}} + If you are running an embedded cassandra you can directly use the StorageProxy for faster performance, + {{{ + #!java + //replace lines11-13 with + List<RowMutation> mutations = new ArrayList<RowMutation>(); + + // replace lines 20-27 with + RowMutation change = new RowMutation(keyspaceName, UUIDSerializer.get().toByteBuffer(uuid)); + ColumnPath cp = new ColumnPath(cfName).setColumn(C_NAME.getBytes()); + change.add(new QueryPath(cp), ByteBuffer.wrap(payloadBytes), HFactory.createClock(), THRIFT_TTL); + mutations.add(change); + + // replace line 37 with + StorageProxy.mutate(mutations, ConsistencyLevel.ONE); + }}} +
