cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject [1/3] git commit: cleanup
Date Mon, 20 Oct 2014 18:41:59 GMT
Repository: cassandra
Updated Branches:
  refs/heads/cassandra-2.1 ba681300b -> abde62d04
  refs/heads/trunk 8ee739419 -> 49833b943


cleanup


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/abde62d0
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/abde62d0
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/abde62d0

Branch: refs/heads/cassandra-2.1
Commit: abde62d04a6ea333b5107e03b0e1a983f9b3b733
Parents: ba68130
Author: Jonathan Ellis <jbellis@apache.org>
Authored: Sat Oct 11 17:09:13 2014 -0500
Committer: Jonathan Ellis <jbellis@apache.org>
Committed: Mon Oct 20 11:38:43 2014 -0700

----------------------------------------------------------------------
 src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/abde62d0/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java b/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java
index eedaa17..d052d73 100644
--- a/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java
+++ b/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java
@@ -32,7 +32,6 @@ import com.google.common.collect.AbstractIterator;
 import com.google.common.collect.Iterables;
 import com.google.common.collect.Maps;
 
-import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang.StringUtils;
 
 import org.apache.cassandra.hadoop.HadoopCompat;
@@ -580,7 +579,7 @@ public class CqlRecordReader extends RecordReader<Long, Row>
         String query = "SELECT column_name, component_index, type FROM system.schema_columns
WHERE keyspace_name='" +
                        keyspace + "' and columnfamily_name='" + cfName + "'";
         List<Row> rows = session.execute(query).all();
-        if (CollectionUtils.isEmpty(rows))
+        if (rows.isEmpty())
         {
             throw new RuntimeException("No table metadata found for " + keyspace + "." +
cfName);
         }


Mime
View raw message