Skip to content

Instantly share code, notes, and snippets.

View stuhood's full-sized avatar

Stu Hood stuhood

141 followers · 16 following
View GitHub Profile
@stuhood
stuhood / gist:95473
Created April 14, 2009 22:28
(import '(java.io BufferedReader IOException InputStream InputStreamReader OutputStreamWriter)
'(java.net URL URLConnection URLEncoder)
'(sun.misc BASE64Encoder))
(def update-url "https://twitter.com/statuses/update.xml")
(defn creds [username password]
(.trim (.encode (BASE64Encoder.) (.getBytes (str username ":" password)))))
(defn twitter [username password text]
@stuhood
stuhood / gist:322436
Created March 5, 2010 03:56 — forked from afex/gist:321256
/**
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with this
* work for additional information regarding copyright ownership. The ASF
* licenses this file to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
@stuhood
stuhood / gist:705770
Created November 18, 2010 22:21
record Column {
bytes name;
bytes value;
long timestamp;
union { int, null } ttl;
}
// becomes...
record Column {
@stuhood
stuhood / gist:705783
Created November 18, 2010 22:26
record Column {
bytes name;
bytes value;
long timestamp;
union { int, null } ttl;
}
// becomes...
record Column {
@stuhood
stuhood / gist:784987
Created January 18, 2011 19:35
diff --git a/src/avro/internode.genavro b/src/avro/internode.genavro
index 4ab75dc..1e7d43b 100644
--- a/src/avro/internode.genavro
+++ b/src/avro/internode.genavro
@@ -61,7 +61,7 @@ protocol InterNode {
union { null, double} memtable_operations_in_millions = null;
union { int, null } id;
union { array<ColumnDef>, null } column_metadata;
- union { boolean, null } replicate_on_write;
+ union { null, boolean } replicate_on_write = null;
@stuhood
stuhood / gist:805333
Created February 1, 2011 02:57
DEBUG 02:54:02,349 get_slice
DEBUG 02:54:02,355 weakread reading SliceFromReadCommand(table='Keyspace1', key='key26', column_parent='QueryPath(columnFamilyName='Standard1', superColumnName='null', columnName='null')', start='', finish='', reversed=true, count=1000000) locally
DEBUG 02:54:02,356 weakreadlocal reading SliceFromReadCommand(table='Keyspace1', key='key26', column_parent='QueryPath(columnFamilyName='Standard1', superColumnName='null', columnName='null')', start='', finish='', reversed=true, count=1000000)
WARN 02:54:02,356 Sleeeping...
WARN 02:54:02,440 Scores: {}
WARN 02:54:02,540 Scores: {}
WARN 02:54:02,640 Scores: {}
WARN 02:54:02,740 Scores: {}
WARN 02:54:02,841 Scores: {}
WARN 02:54:02,941 Scores: {}
@stuhood
stuhood / gist:805341
Created February 1, 2011 03:00
WARN 02:59:27,043 Scores: {/10.160.181.104=4.397948694533098, /10.160.135.188=8.000499155265965}
WARN 02:59:27,143 Scores: {/10.160.181.104=4.397948694533098, /10.160.135.188=8.000499155265965}
WARN 02:59:27,243 Scores: {/10.160.181.104=4.397948694533098, /10.160.135.188=8.000499155265965}
WARN 02:59:27,343 Scores: {/10.160.181.104=4.397948694533098, /10.160.135.188=8.000499155265965}
WARN 02:59:27,443 Scores: {/10.160.181.104=4.397948694533098, /10.160.135.188=8.000499155265965}
WARN 02:59:27,543 Scores: {/10.160.181.104=4.397948694533098, /10.160.135.188=8.000499155265965}
DEBUG 02:59:27,639 get_slice
DEBUG 02:59:27,639 weakread reading SliceFromReadCommand(table='Keyspace1', key='key9', column_parent='QueryPath(columnFamilyName='Standard1', superColumnName='null', columnName='null')', start='', finish='', reversed=true, count=1000000) locally
DEBUG 02:59:27,639 weakreadlocal reading SliceFromReadCommand(table='Keyspace1', key='key9', column_parent='QueryPath(columnFamilyName='Standard1', superColumnN
@stuhood
stuhood / finagle-post-close-stack.txt
Created February 1, 2011 20:39
2011-02-03 15:01:38
Full thread dump Java HotSpot(TM) 64-Bit Server VM (17.1-b03-307 mixed mode):
"Attach Listener" daemon prio=9 tid=101a80000 nid=0x1179e8000 waiting on condition [00000000]
java.lang.Thread.State: RUNNABLE
"DestroyJavaVM" prio=5 tid=101802800 nid=0x100501000 waiting on condition [00000000]
java.lang.Thread.State: RUNNABLE
"Hashed wheel timer #1" prio=5 tid=11621f800 nid=0x117e26000 waiting on condition [117e25000]
@stuhood
stuhood / gist:808398
Created February 2, 2011 20:49
Exception in thread "main" com.twitter.finagle.WriteException: java.util.concurrent.RejectedExecutionException
at com.twitter.finagle.channel.ChannelServiceFactory$$anonfun$make$1.apply(ChannelService.scala:110)
at com.twitter.finagle.channel.ChannelServiceFactory$$anonfun$make$1.apply(ChannelService.scala:104)
at com.twitter.finagle.util.RichChannelFuture$$anon$1.operationComplete(ChannelFuture.scala:27)
at org.jboss.netty.channel.DefaultChannelFuture.notifyListener(DefaultChannelFuture.java:381)
at org.jboss.netty.channel.DefaultChannelFuture.addListener(DefaultChannelFuture.java:148)
at com.twitter.finagle.util.RichChannelFuture.apply(ChannelFuture.scala:25)
at com.twitter.finagle.channel.ChannelServiceFactory.make(ChannelService.scala:104)
at com.twitter.finagle.channel.ChannelServiceFactory.make(ChannelService.scala:91)
at com.twitter.finagle.pool.CachingPool.make(CachingPool.scala:65)
@stuhood
stuhood / gist:836701
Created February 21, 2011 05:43
diff --git a/test/unit/org/apache/cassandra/streaming/StreamingTransferTest.java b/test/unit/org/apache/cassandra/streaming/StreamingTransferTest.java
index abf867b..088b3db 100644
--- a/test/unit/org/apache/cassandra/streaming/StreamingTransferTest.java
+++ b/test/unit/org/apache/cassandra/streaming/StreamingTransferTest.java
@@ -183,7 +183,7 @@ public class StreamingTransferTest extends CleanupHelper
}
StreamOutSession session = StreamOutSession.create(keyspace, LOCAL, null);
- StreamOut.transferSSTables(session, ssTableReaders, ranges);
+ StreamOut.transferSSTables(session, ssTableReaders, ranges, OperationType.BOOTSTRAP);