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/cassandra-1.1 Commit: dbc0f599fe83651369802b98b8349331d1f617b8 Parents: a3fe297 Author: Jonathan Ellis <jbel...@apache.org> Authored: Tue Apr 10 16:05:58 2012 -0500 Committer: Jonathan Ellis <jbel...@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);
