[Amdatu-commits] SVN r605 - sandbox/ivol/cassandra-gadget/src/main/java/org/amdatu/cassandra/gadget/service

[subvers...@amdatu.org]

Author: ivol37 at gmail.com
Date: Wed Jan 12 16:20:26 2011
New Revision: 605

Log:


Modified:
   
sandbox/ivol/cassandra-gadget/src/main/java/org/amdatu/cassandra/gadget/service/CassandraClientGadgetImpl.java

Modified: 
sandbox/ivol/cassandra-gadget/src/main/java/org/amdatu/cassandra/gadget/service/CassandraClientGadgetImpl.java
==============================================================================
--- 
sandbox/ivol/cassandra-gadget/src/main/java/org/amdatu/cassandra/gadget/service/CassandraClientGadgetImpl.java
      (original)
+++ 
sandbox/ivol/cassandra-gadget/src/main/java/org/amdatu/cassandra/gadget/service/CassandraClientGadgetImpl.java
      Wed Jan 12 16:20:26 2011
@@ -263,8 +263,6 @@
 
         // Set key range to maximum ROW_LIMIT results
         KeyRange range = new KeyRange(ROW_LIMIT);
-        range.setStart_key(EMPTY);
-        range.setEnd_key(EMPTY);
 
         Iface cs = m_daemon.getCassandraServer();
         cs.set_keyspace(keyspace);
@@ -275,11 +273,11 @@
             // This may be a bangling row key marked for removal, check that!
             if (keySlice.getColumnsSize() > 0) {
                 keys.add(new String(keySlice.getKey(), "UTF-8"));
+            } else {
+                m_logService.log(LogService.LOG_WARNING, "Row key '" + 
keySlice.getKey() + "' has no columns");
             }
         }
-        m_logService.log(LogService.LOG_DEBUG, "Found " + keys.size() + " keys 
for ColumnFamily '"
-            + columnFamilyName
-            + "' in getRowKeys");
+        m_logService.log(LogService.LOG_DEBUG, "Found " + keys.size() + " keys 
for ColumnFamily '" + columnFamilyName + "' in keyspace '" + keyspace + "'");
         return keys;
     }