public class QueryFilter
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
java.lang.String |
cfName |
IDiskAtomFilter |
filter |
DecoratedKey |
key |
long |
timestamp |
Constructor and Description |
---|
QueryFilter(DecoratedKey key,
java.lang.String cfName,
IDiskAtomFilter filter,
long timestamp) |
Modifier and Type | Method and Description |
---|---|
static void |
collateColumns(ColumnFamily returnCF,
java.util.List<? extends java.util.Iterator<Column>> toCollate,
IDiskAtomFilter filter,
int gcBefore,
long timestamp) |
void |
collateColumns(ColumnFamily returnCF,
java.util.List<? extends java.util.Iterator<Column>> toCollate,
int gcBefore) |
void |
collateOnDiskAtom(ColumnFamily returnCF,
java.util.Iterator<? extends OnDiskAtom> toCollate,
int gcBefore)
When there is only a single source of atoms, we can skip the collate step
|
static void |
collateOnDiskAtom(ColumnFamily returnCF,
java.util.List<? extends java.util.Iterator<? extends OnDiskAtom>> toCollate,
IDiskAtomFilter filter,
int gcBefore,
long timestamp) |
void |
collateOnDiskAtom(ColumnFamily returnCF,
java.util.List<? extends java.util.Iterator<? extends OnDiskAtom>> toCollate,
int gcBefore) |
static java.util.Iterator<Column> |
gatherTombstones(ColumnFamily returnCF,
java.util.Iterator<? extends OnDiskAtom> iter)
Given an iterator of on disk atom, returns an iterator that filters the tombstone range
markers adding them to
returnCF and returns the normal column. |
OnDiskAtomIterator |
getColumnFamilyIterator(ColumnFamily cf) |
java.lang.String |
getColumnFamilyName() |
static QueryFilter |
getIdentityFilter(DecoratedKey key,
java.lang.String cfName,
long timestamp)
return a QueryFilter object that includes every column in the row.
|
OnDiskAtomIterator |
getMemtableColumnIterator(Memtable memtable) |
static QueryFilter |
getNamesFilter(DecoratedKey key,
java.lang.String cfName,
java.util.SortedSet<java.nio.ByteBuffer> columns,
long timestamp) |
static QueryFilter |
getSliceFilter(DecoratedKey key,
java.lang.String cfName,
java.nio.ByteBuffer start,
java.nio.ByteBuffer finish,
boolean reversed,
int limit,
long timestamp) |
OnDiskAtomIterator |
getSSTableColumnIterator(SSTableReader sstable) |
OnDiskAtomIterator |
getSSTableColumnIterator(SSTableReader sstable,
FileDataInput file,
DecoratedKey key,
RowIndexEntry indexEntry) |
boolean |
shouldInclude(SSTableReader sstable) |
java.lang.String |
toString() |
public final DecoratedKey key
public final java.lang.String cfName
public final IDiskAtomFilter filter
public final long timestamp
public QueryFilter(DecoratedKey key, java.lang.String cfName, IDiskAtomFilter filter, long timestamp)
public OnDiskAtomIterator getMemtableColumnIterator(Memtable memtable)
public OnDiskAtomIterator getColumnFamilyIterator(ColumnFamily cf)
public OnDiskAtomIterator getSSTableColumnIterator(SSTableReader sstable)
public OnDiskAtomIterator getSSTableColumnIterator(SSTableReader sstable, FileDataInput file, DecoratedKey key, RowIndexEntry indexEntry)
public void collateOnDiskAtom(ColumnFamily returnCF, java.util.List<? extends java.util.Iterator<? extends OnDiskAtom>> toCollate, int gcBefore)
public static void collateOnDiskAtom(ColumnFamily returnCF, java.util.List<? extends java.util.Iterator<? extends OnDiskAtom>> toCollate, IDiskAtomFilter filter, int gcBefore, long timestamp)
public void collateOnDiskAtom(ColumnFamily returnCF, java.util.Iterator<? extends OnDiskAtom> toCollate, int gcBefore)
public void collateColumns(ColumnFamily returnCF, java.util.List<? extends java.util.Iterator<Column>> toCollate, int gcBefore)
public static void collateColumns(ColumnFamily returnCF, java.util.List<? extends java.util.Iterator<Column>> toCollate, IDiskAtomFilter filter, int gcBefore, long timestamp)
public static java.util.Iterator<Column> gatherTombstones(ColumnFamily returnCF, java.util.Iterator<? extends OnDiskAtom> iter)
returnCF
and returns the normal column.public java.lang.String getColumnFamilyName()
public static QueryFilter getSliceFilter(DecoratedKey key, java.lang.String cfName, java.nio.ByteBuffer start, java.nio.ByteBuffer finish, boolean reversed, int limit, long timestamp)
key
- the row to slicecfName
- column family to querystart
- column to start slice at, inclusive; empty for "the first column"finish
- column to stop slice at, inclusive; empty for "the last column"reversed
- true to start with the largest column (as determined by configured sort order) instead of smallestlimit
- maximum number of non-deleted columns to returntimestamp
- time to use for determining expiring columns' statepublic static QueryFilter getIdentityFilter(DecoratedKey key, java.lang.String cfName, long timestamp)
public static QueryFilter getNamesFilter(DecoratedKey key, java.lang.String cfName, java.util.SortedSet<java.nio.ByteBuffer> columns, long timestamp)
key
- the row to slicecfName
- column family to querycolumns
- the column names to restrict the results to, sorted in comparator orderpublic java.lang.String toString()
toString
in class java.lang.Object
public boolean shouldInclude(SSTableReader sstable)
Copyright © 2014 The Apache Software Foundation