Repository: cassandra Updated Branches: refs/heads/cassandra-3.0 0afe4beeb -> af0678dd4
Fix build Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/af0678dd Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/af0678dd Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/af0678dd Branch: refs/heads/cassandra-3.0 Commit: af0678dd48389a05b0fffb89d21b4e2f9d91f9d6 Parents: 0afe4be Author: Sylvain Lebresne <[email protected]> Authored: Wed Sep 16 09:44:16 2015 +0200 Committer: Sylvain Lebresne <[email protected]> Committed: Wed Sep 16 09:44:16 2015 +0200 ---------------------------------------------------------------------- .../cassandra/hadoop/cql3/CqlInputFormat.java | 23 +++++++++++++++----- 1 file changed, 17 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/af0678dd/src/java/org/apache/cassandra/hadoop/cql3/CqlInputFormat.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/hadoop/cql3/CqlInputFormat.java b/src/java/org/apache/cassandra/hadoop/cql3/CqlInputFormat.java index 7699f29..3f74c33 100644 --- a/src/java/org/apache/cassandra/hadoop/cql3/CqlInputFormat.java +++ b/src/java/org/apache/cassandra/hadoop/cql3/CqlInputFormat.java @@ -19,19 +19,30 @@ package org.apache.cassandra.hadoop.cql3; import java.io.IOException; import java.util.*; -import java.util.concurrent.* +import java.util.concurrent.*; + +import com.datastax.driver.core.Host; +import com.datastax.driver.core.Metadata; +import com.datastax.driver.core.ResultSet; +import com.datastax.driver.core.Row; +import com.datastax.driver.core.Session; +import com.datastax.driver.core.TokenRange; +import org.apache.hadoop.conf.Configuration; +import org.apache.hadoop.mapred.InputSplit; +import org.apache.hadoop.mapred.JobConf; +import org.apache.hadoop.mapred.RecordReader; +import org.apache.hadoop.mapred.Reporter; +import org.apache.hadoop.mapreduce.JobContext; +import org.apache.hadoop.mapreduce.TaskAttemptContext; +import org.apache.hadoop.mapreduce.TaskAttemptID; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.datastax.driver.core.*; import org.apache.cassandra.db.SystemKeyspace; import org.apache.cassandra.dht.*; +import org.apache.cassandra.thrift.KeyRange; import org.apache.cassandra.hadoop.*; -import org.apache.hadoop.conf.Configuration; -import org.apache.hadoop.mapred.*; -import org.apache.hadoop.mapreduce.*; -import com.datastax.driver.core.Row; /** * Hadoop InputFormat allowing map/reduce against Cassandra rows within one ColumnFamily.
