natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

use isSuper 

git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@758978 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Jonathan Ellis 2009-03-27 02:19:40 +00:00
parent def1edd1fe
commit 22c5262720
1 changed files with 9 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/org/apache/cassandra/db/CountFilter.java
View File

@ -21,7 +21,6 @@ import java.io.DataInputStream;
import java.io.IOException;
import java.util.Collection;
import org.apache.cassandra.config.DatabaseDescriptor;
import org.apache.cassandra.io.DataInputBuffer;
import org.apache.cassandra.io.SSTable;
@ -37,19 +36,19 @@ public class CountFilter implements IFilter
{
private long countLimit_;
private boolean isDone_;
CountFilter(int countLimit)
{
countLimit_ = countLimit;
countLimit_ = countLimit;
isDone_ = false;
}
public ColumnFamily filter(String cfNameParam, ColumnFamily columnFamily)
{
String[] values = RowMutation.getColumnAndColumnFamily(cfNameParam);
if ( columnFamily == null )
return columnFamily;
String cfName = columnFamily.name();
ColumnFamily filteredCf = new ColumnFamily(cfName);
if( countLimit_ <= 0 )
@ -71,7 +70,7 @@ public class CountFilter implements IFilter
}
}
}
else if(values.length == 2 && DatabaseDescriptor.getColumnType(cfName).equals("Super"))
else if(values.length == 2 && columnFamily.isSuper())
{
Collection<IColumn> columns = columnFamily.getAllColumns();
for(IColumn column : columns)
@ -91,14 +90,14 @@ public class CountFilter implements IFilter
}
}
}
}
else
}
else
{
throw new UnsupportedOperationException();
}
return filteredCf;
}
public IColumn filter(IColumn column, DataInputStream dis) throws IOException
{
countLimit_--;
@ -108,7 +107,7 @@ public class CountFilter implements IFilter
}
return column;
}
public boolean isDone()
{
return isDone_;