You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by db...@apache.org on 2014/10/24 04:54:50 UTC
git commit: remove dead code
Repository: cassandra
Updated Branches:
refs/heads/cassandra-2.1 8e5fdc2f9 -> 1d5d30327
remove dead code
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/1d5d3032
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/1d5d3032
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/1d5d3032
Branch: refs/heads/cassandra-2.1
Commit: 1d5d30327541e1f91cd6f4e8cd9fc5a39a146aa2
Parents: 8e5fdc2
Author: Dave Brosius <db...@mebigfatguy.com>
Authored: Thu Oct 23 22:54:07 2014 -0400
Committer: Dave Brosius <db...@mebigfatguy.com>
Committed: Thu Oct 23 22:54:07 2014 -0400
----------------------------------------------------------------------
src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/1d5d3032/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 1efde47..7ef592f 100644
--- a/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java
+++ b/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java
@@ -97,6 +97,7 @@ public class CqlRecordReader extends RecordReader<Long, Row>
super();
}
+ @Override
public void initialize(InputSplit split, TaskAttemptContext context) throws IOException
{
this.split = (ColumnFamilySplit) split;
@@ -109,7 +110,6 @@ public class CqlRecordReader extends RecordReader<Long, Row>
partitioner = ConfigHelper.getInputPartitioner(conf);
inputColumns = CqlConfigHelper.getInputcolumns(conf);
userDefinedWhereClauses = CqlConfigHelper.getInputWhereClauses(conf);
- Optional<Integer> pageRowSizeOptional = CqlConfigHelper.getInputPageRowSize(conf);
try
{