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=1&rev2=2 -------------------------------------------------- Here's a super simple example written in java and using Hector. It uses a column family according to the LogEntry's category, and puts the payload directly into a column name "scribePayload". {{{ + #!java class ScribeToCassandraService implements com.facebook.scribe.scribe.Iface { private static final String CLUSTER_NAME = "myCluster"; @@ -15, +16 @@ public ResultCode Log(final List<LogEntry> logEntries) throws TException { Cluster cluster = HFactory.getOrCreateCluster(CLUSTER_NAME, HOST_PORT); - Mutator<UUID> mutator = HFactory.createMutator(HFactory.createKeyspace(KEYSPACE, cluster), UUIDSerializer.get()); + Mutator<UUID> mutator = HFactory.createMutator( + HFactory.createKeyspace(KEYSPACE, cluster), + UUIDSerializer.get()); + for (LogEntry logEntry : logEntries) { try{
