Modifier and Type | Class and Description |
---|---|
static class |
ColumnFamilyStore.AbstractScanIterator |
Modifier and Type | Method and Description |
---|---|
static CloseableIterator<Row> |
RowIteratorFactory.getIterator(java.lang.Iterable<Memtable> memtables,
java.util.Collection<SSTableReader> sstables,
RowPosition startWith,
RowPosition stopAt,
QueryFilter filter,
ColumnFamilyStore cfs)
Get a row iterator over the provided memtables and sstables, between the provided keys
and filtered by the queryfilter.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ICountableColumnIterator |
interface |
ISSTableColumnIterator |
interface |
OnDiskAtomIterator |
Modifier and Type | Class and Description |
---|---|
class |
LazyColumnIterator |
class |
SimpleAbstractColumnIterator |
class |
SSTableNamesIterator |
class |
SSTableSliceIterator
A Column Iterator over SSTable
|
Modifier and Type | Interface and Description |
---|---|
interface |
ICompactionScanner
An ICompactionScanner is an abstraction allowing multiple SSTableScanners to be
chained together under the hood.
|
Modifier and Type | Method and Description |
---|---|
abstract CloseableIterator<AbstractCompactedRow> |
AbstractCompactionIterable.iterator() |
CloseableIterator<AbstractCompactedRow> |
CompactionIterable.iterator() |
CloseableIterator<AbstractCompactedRow> |
ParallelCompactionIterable.iterator() |
Modifier and Type | Method and Description |
---|---|
static void |
PrecompactedRow.merge(ColumnFamily returnCF,
java.util.List<CloseableIterator<IColumn>> data,
SecondaryIndexManager.Updater indexer) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractColumnIterator |
Modifier and Type | Method and Description |
---|---|
static CloseableIterator<IColumn> |
QueryFilter.gatherTombstones(ColumnFamily returnCF,
CloseableIterator<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. |
Modifier and Type | Method and Description |
---|---|
static CloseableIterator<IColumn> |
QueryFilter.gatherTombstones(ColumnFamily returnCF,
CloseableIterator<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. |
Modifier and Type | Method and Description |
---|---|
void |
QueryFilter.collateColumns(ColumnFamily returnCF,
java.util.List<? extends CloseableIterator<IColumn>> toCollate,
int gcBefore) |
void |
QueryFilter.collateOnDiskAtom(ColumnFamily returnCF,
java.util.List<? extends CloseableIterator<OnDiskAtom>> toCollate,
int gcBefore) |
Modifier and Type | Class and Description |
---|---|
class |
KeyIterator |
class |
ReducingKeyIterator
Caller must acquire and release references to the sstables used here.
|
class |
SSTableBoundedScanner
A SSTableScanner that only reads key in a given range (for validation compaction).
|
class |
SSTableIdentityIterator |
class |
SSTableScanner |
Modifier and Type | Interface and Description |
---|---|
interface |
IMergeIterator<In,Out> |
Modifier and Type | Class and Description |
---|---|
class |
MergeIterator<In,Out>
Merges sorted input iterators which individually contain unique items.
|
Modifier and Type | Field and Description |
---|---|
protected java.util.List<? extends CloseableIterator<In>> |
MergeIterator.iterators |
Modifier and Type | Method and Description |
---|---|
static <T> CloseableIterator<T> |
FBUtilities.closeableIterator(java.util.Iterator<T> iterator) |
Modifier and Type | Method and Description |
---|---|
java.lang.Iterable<? extends CloseableIterator<In>> |
IMergeIterator.iterators() |
java.lang.Iterable<? extends CloseableIterator<In>> |
MergeIterator.iterators() |
Modifier and Type | Method and Description |
---|---|
static <In,Out> IMergeIterator<In,Out> |
MergeIterator.get(java.util.List<? extends CloseableIterator<In>> sources,
java.util.Comparator<In> comparator,
MergeIterator.Reducer<In,Out> reducer) |
Constructor and Description |
---|
MergeIterator.Candidate(CloseableIterator<In> iter,
java.util.Comparator<In> comp) |
Constructor and Description |
---|
MergeIterator(java.util.List<? extends CloseableIterator<In>> iters,
MergeIterator.Reducer<In,Out> reducer) |
Copyright © 2014 The Apache Software Foundation