You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jb...@apache.org on 2012/04/11 20:26:43 UTC
[9/21] git commit: inline widerows field
inline widerows field
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/dbc0f599
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/dbc0f599
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/dbc0f599
Branch: refs/heads/trunk
Commit: dbc0f599fe83651369802b98b8349331d1f617b8
Parents: a3fe297
Author: Jonathan Ellis <jb...@apache.org>
Authored: Tue Apr 10 16:05:58 2012 -0500
Committer: Jonathan Ellis <jb...@apache.org>
Committed: Wed Apr 11 13:24:35 2012 -0500
----------------------------------------------------------------------
.../cassandra/hadoop/ColumnFamilyRecordReader.java | 3 +--
1 files changed, 1 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/dbc0f599/src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordReader.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordReader.java b/src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordReader.java
index 89cf840..483c040 100644
--- a/src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordReader.java
+++ b/src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordReader.java
@@ -71,7 +71,6 @@ public class ColumnFamilyRecordReader extends RecordReader<ByteBuffer, SortedMap
private ConsistencyLevel consistencyLevel;
private int keyBufferSize = 8192;
private List<IndexExpression> filter;
- private boolean widerows;
public ColumnFamilyRecordReader()
{
@@ -140,7 +139,7 @@ public class ColumnFamilyRecordReader extends RecordReader<ByteBuffer, SortedMap
KeyRange jobRange = ConfigHelper.getInputKeyRange(conf);
filter = jobRange == null ? null : jobRange.row_filter;
predicate = ConfigHelper.getInputSlicePredicate(conf);
- widerows = ConfigHelper.getInputIsWide(conf);
+ boolean widerows = ConfigHelper.getInputIsWide(conf);
isEmptyPredicate = isEmptyPredicate(predicate);
totalRowCount = ConfigHelper.getInputSplitSize(conf);
batchSize = ConfigHelper.getRangeBatchSize(conf);