Skip to content

Instantly share code, notes, and snippets.

View zznate's full-sized avatar

Nate McCall zznate

129 followers · 7 following
View GitHub Profile
@zznate
zznate / Thrift in maven
Created September 28, 2010 18:44
Add a repository declaration for mvn.riptano.com:
<repositories>
<repository>
<id>riptano</id>
<name>riptano</name>
<url>http://mvn.riptano.com/content/repositories/public/</url>
</repository>
</repositories>
@zznate
zznate / gist:611655
Created October 5, 2010 14:32
cassandra.yaml:
- name: Indexed1
column_metadata:
- name: price
validator_class: LongType
index_type: KEYS
column_metadata:
- name: airport
index_type: KEYS
@zznate
zznate / gist:779810
Created January 14, 2011 16:15
<%@ page contentType="text/html; charset=UTF-8" %>
<%@ taglib uri="http://java.sun.com/jsp/jstl/core" prefix="c" %>
<%@ taglib uri="hectortags" prefix="h" %>
<%@ taglib prefix="fn" uri="http://java.sun.com/jsp/jstl/functions" %>
<html>
<head><title>Hector Column Example</title></head>
<body bgcolor="white">
<p>
<h:hectorColumn tagContextName="twissjavaTagContext" columnFamily="User" key="${param.user}" columnNames="password,user" columnValueSerializer="${h:stringSerializer()}">
${queryResult}
@zznate
zznate / gist:790491
Created January 21, 2011 21:46
embeddedserver diff
.java b/core/src/main/java/me/prettyprint/cassandra/testutils/EmbeddedServerHelper.java
index 7770070..3e3fbb5 100644
--- a/core/src/main/java/me/prettyprint/cassandra/testutils/EmbeddedServerHelper.java
+++ b/core/src/main/java/me/prettyprint/cassandra/testutils/EmbeddedServerHelper.java
@@ -5,16 +5,21 @@ import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
@zznate
zznate / gist:822680
Created February 11, 2011 17:09
public interface HColumnFamily<K, N> {
HColumnFamily<K, N> addKey(K key);
HColumnFamily<K, N> addKeys(Iterable<K> keys);
HColumnFamily<K, N> addColumn(HColumn<N, ?> column);
HColumnFamily<K, N> addColumns(List<HColumn<N, ?>> columns);
@zznate
zznate / gist:832728
Created February 17, 2011 21:19
Snippet from test case for new HColumnFamily
Where we have the following generic declaration of a type K for the key an N for the column name: HColumnFamily<K,N>
@Before
public void setupLocal() {
setupClient();
Cluster cluster = new ThriftCluster("Test Cluster", cassandraHostConfigurator);
keyspace = HFactory.createKeyspace("Keyspace1", cluster);
Mutator<String> mutator = HFactory.createMutator(keyspace, StringSerializer.get());
mutator.addInsertion("zznate", "Standard1", HFactory.createStringColumn("email", "[email protected]"));
mutator.addInsertion("zznate", "Standard1", HFactory.createColumn("int", 1, StringSerializer.get(), IntegerSerializer.get()));
@zznate
zznate / multiget_slice test code
Created March 1, 2011 18:41
Example test code which passes:
public void testMultigetSerializers() {
Mutator m = createMutator(keyspace, is);
m.addInsertion(5, cf,
HFactory.createColumn(10, new byte[0], is, bas));
m.execute();
MultigetSliceQuery<Integer, Integer,byte[]> query = HFactory.createMultigetSliceQuery(keyspace, is, is, bas);
query.setColumnFamily(cf).setKeys(new Integer[]{5}).setColumnNames(new Integer[]{10});
QueryResult<Rows<Integer,Integer,byte[]>> result = query.execute();
System.out.println(result.toString());
@zznate
zznate / sample1
Created July 14, 2011 20:15
sample code
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.UUID;
import me.prettyprint.cassandra.serializers.BytesArraySerializer;
import me.prettyprint.cassandra.serializers.StringSerializer;
import me.prettyprint.cassandra.serializers.UUIDSerializer;
import me.prettyprint.cassandra.service.template.ColumnFamilyResult;
@zznate
zznate / gist:1927634
Created February 27, 2012 22:39
Cassandra cassandra = new Cassandra();
Keyspace keyspace = cassandra.getKeyspace("MyKeyspace");
ColumnFamily columnFamily = keyspace.getColumnFamily("Users");
Row row = new Row()
.put("username", "zznate")
.put("email","[email protected]")
.increment("hits",1);
@zznate
zznate / gist:1933662
Created February 28, 2012 17:00
public Integer call() {
Mutator<String> mutator = HFactory.createMutator(tutorialKeyspace, StringSerializer.get());
int count = 0;
for (int x=0; x<5000; x++) {
mutator.addInsertion(myKey,CF_TIMESERIES_SINGLE_ROW, buildColumnFor(x));
}
mutator.execute();
log.debug("Inserted {} rows", count);
return Integer.valueOf(count);