amorton

Index: src/java/org/apache/cassandra/db/SuperColumn.java
===================================================================
--- src/java/org/apache/cassandra/db/SuperColumn.java	(date 1300200460000)
+++ src/java/org/apache/cassandra/db/SuperColumn.java	(revision )
@@ -359,8 +359,11 @@
         /* read the number of columns */
         int size = dis.readInt();
         ColumnSerializer serializer = Column.serializer();
-        ColumnSortedMap preSortedMap = new ColumnSortedMap(comparator, serializer, dis, size);
-        SuperColumn superColumn = new SuperColumn(name, new ConcurrentSkipListMap<ByteBuffer,IColumn>(preSortedMap));

amorton

Turns out I don't know much about Auckland, but here goes...

• Caving in Waitomo http://www.waitomo.com/

• Aquarium, bit overpriced and old but there you go http://kellytarltons.co.nz/

• You can jump of this if it's your thing http://www.skycityauckland.co.nz/Attractions/Skytower.html

• Hot mud and party time in Roto-Vegas http://www.rotoruanz.com/

amorton

# in irb to get any variable regardless of scope 
obj.instance_variable_get("@var_name") 

# in irb to exec any function regardless of scope 
obj.send(:func_name)

amorton

#used as part of a unit test
def _compare_directories(self, expected_dir, actual_dir, header=None):
    """Compares two directories and diffs any different files.
    
    The file list of both directories must match and the files must match.
    Sub directories are not considered as I don't need to in my case.
    
    The diff will not show that a file was deleted from one side. It shows
    that all the lines were removed.
    

amorton

if __name__ == "__main__":
    action = sys.argv[1] if len(sys.argv) > 1 else None
    args = [
        token 
        for token in sys.argv[2:] 
        if token.find("=") < 0
    ]
    kwargs = dict(
        token.split("=") 
        for token in sys.argv[2:] 

amorton

diff --git a/src/java/org/apache/cassandra/db/columniterator/SSTableNamesIterator.java b/src/java/org/apache/cassandra/db/columniterator/SSTableNamesIterator.java
index 6cbc64b..014ce2c 100644
--- a/src/java/org/apache/cassandra/db/columniterator/SSTableNamesIterator.java
+++ b/src/java/org/apache/cassandra/db/columniterator/SSTableNamesIterator.java
@@ -184,6 +184,7 @@ public class SSTableNamesIterator extends SimpleAbstractColumnIterator implement
                 }
             }
         }
+        logger.info("Column Page Count {}/{}", Integer.toString(indexList.size()), Integer.toString(ranges.size()));
     }

amorton

"""Tool for profiling Cassandra query performance. 

Tests are run by profile() multiple times and the 'Read Latency' is 
extracted using node tool.  

Usage:

#Create the schema using the cassandra-cli. 

create keyspace query

amorton

In [6]: import numpy as np

In [7]: np.random.po
np.random.poisson  np.random.power    

In [7]: np.random.poisson(100 / 60.0, 60)
Out[7]: 
array([0, 2, 2, 1, 4, 3, 5, 3, 1, 0, 3, 1, 1, 1, 1, 2, 3, 2, 2, 0, 3, 2, 0,
       2, 3, 1, 2, 1, 4, 1, 5, 1, 3, 1, 1, 3, 1, 3, 1, 1, 0, 1, 3, 1, 2, 4,
       2, 3, 4, 2, 3, 3, 4, 3, 3, 1, 2, 3, 1, 1])

amorton

2011-07-26 17:23:34,376 ERROR CliDriver (SessionState.java:printError(343)) - Failed with exception java.io.IOException:java.lang.NullPointerException
java.io.IOException: java.lang.NullPointerException
	at org.apache.hadoop.hive.ql.exec.FetchOperator.getNextRow(FetchOperator.java:341)
	at org.apache.hadoop.hive.ql.exec.FetchTask.fetch(FetchTask.java:133)
	at org.apache.hadoop.hive.ql.Driver.getResults(Driver.java:1114)
	at org.apache.hadoop.hive.cli.CliDriver.processCmd(CliDriver.java:187)
	at org.apache.hadoop.hive.cli.CliDriver.processLine(CliDriver.java:241)
	at org.apache.hadoop.hive.cli.CliDriver.main(CliDriver.java:456)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)

amorton

diff --git a/build.xml b/build.xml
index e5ec33b..c05f24c 100644
--- a/build.xml
+++ b/build.xml
@@ -99,8 +99,8 @@
   <!-- Directory for temporary files. -->
   <property name="dist.tmp" value="${dist.dir}/tmp"/>
   
-  <property name="javac.source" value="1.2"/>
-  <property name="javac.target" value="1.1"/>