public interface IDiskAtomFilter
Modifier and Type | Interface and Description |
---|---|
static class |
IDiskAtomFilter.Serializer |
Modifier and Type | Method and Description |
---|---|
IDiskAtomFilter |
cloneShallow() |
void |
collectReducedColumns(ColumnFamily container,
java.util.Iterator<Column> reducedColumns,
int gcBefore,
long now)
collects columns from reducedColumns into returnCF.
|
ColumnCounter |
columnCounter(AbstractType<?> comparator,
long now) |
java.util.Comparator<Column> |
getColumnComparator(AbstractType<?> comparator) |
OnDiskAtomIterator |
getColumnFamilyIterator(DecoratedKey key,
ColumnFamily cf)
returns an iterator that returns columns from the given columnFamily
matching the Filter criteria in sorted order.
|
int |
getLiveCount(ColumnFamily cf,
long now) |
OnDiskAtomIterator |
getSSTableColumnIterator(SSTableReader sstable,
DecoratedKey key)
returns an iterator that returns columns from the given SSTable
matching the Filter criteria in sorted order.
|
OnDiskAtomIterator |
getSSTableColumnIterator(SSTableReader sstable,
FileDataInput file,
DecoratedKey key,
RowIndexEntry indexEntry)
Get an iterator that returns columns from the given SSTable using the opened file
matching the Filter criteria in sorted order.
|
boolean |
isReversed() |
boolean |
maySelectPrefix(java.util.Comparator<java.nio.ByteBuffer> cmp,
java.nio.ByteBuffer prefix) |
boolean |
shouldInclude(SSTableReader sstable) |
void |
updateColumnsLimit(int newLimit) |
OnDiskAtomIterator getColumnFamilyIterator(DecoratedKey key, ColumnFamily cf)
OnDiskAtomIterator getSSTableColumnIterator(SSTableReader sstable, FileDataInput file, DecoratedKey key, RowIndexEntry indexEntry)
sstable
- file
- Already opened file data input, saves us opening another onekey
- The key of the row we are about to iterate overOnDiskAtomIterator getSSTableColumnIterator(SSTableReader sstable, DecoratedKey key)
void collectReducedColumns(ColumnFamily container, java.util.Iterator<Column> reducedColumns, int gcBefore, long now)
java.util.Comparator<Column> getColumnComparator(AbstractType<?> comparator)
boolean isReversed()
void updateColumnsLimit(int newLimit)
int getLiveCount(ColumnFamily cf, long now)
ColumnCounter columnCounter(AbstractType<?> comparator, long now)
IDiskAtomFilter cloneShallow()
boolean maySelectPrefix(java.util.Comparator<java.nio.ByteBuffer> cmp, java.nio.ByteBuffer prefix)
boolean shouldInclude(SSTableReader sstable)
Copyright © 2014 The Apache Software Foundation