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=4&rev2=5 -------------------------------------------------- If you are running an embedded cassandra you can directly use the StorageProxy for faster performance, {{{ #!java - //replace lines11-13 with + // replace above lines 11-13 with List<RowMutation> mutations = new ArrayList<RowMutation>(); - // replace lines 20-27 with + // replace above lines 20-27 with + UUID uuid = UUID.fromString(UUIDGenerator.getInstance().generateTimeBasedUUID().toString()); RowMutation change = new RowMutation(keyspaceName, UUIDSerializer.get().toByteBuffer(uuid)); - ColumnPath cp = new ColumnPath(cfName).setColumn(C_NAME.getBytes()); + ColumnPath cp = new ColumnPath(category).setColumn(COLUMN.getBytes()); - change.add(new QueryPath(cp), ByteBuffer.wrap(payloadBytes), HFactory.createClock(), THRIFT_TTL); + change.add(new QueryPath(cp), ByteBuffer.wrap(payloadBytes), HFactory.createClock()); mutations.add(change); - // replace line 37 with + // replace above line 37 with StorageProxy.mutate(mutations, ConsistencyLevel.ONE); }}}
