Package org.apache.cassandra.index.sasi.disk

Class OnDiskIndex

java.lang.Object

org.apache.cassandra.index.sasi.disk.OnDiskIndex

All Implemented Interfaces:

Closeable, AutoCloseable, Iterable<OnDiskIndex.DataTerm>

public class OnDiskIndex
extends Object
implements Iterable<OnDiskIndex.DataTerm>, Closeable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	OnDiskIndex.DataBlock
protected class	OnDiskIndex.DataLevel
class	OnDiskIndex.DataTerm
static enum	OnDiskIndex.IteratorOrder
protected class	OnDiskIndex.Level<T extends OnDiskBlock>
protected class	OnDiskIndex.OnDiskSuperBlock
protected class	OnDiskIndex.PointerBlock
protected class	OnDiskIndex.PointerLevel
protected static class	OnDiskIndex.PointerTerm

Field Summary

Fields

Modifier and Type	Field	Description
protected final AbstractType<?>	comparator
protected final OnDiskIndex.DataLevel	dataLevel
final Descriptor	descriptor
protected final boolean	hasMarkedPartials
protected final MappedBuffer	indexFile
protected final String	indexPath
protected final long	indexSize
protected final com.google.common.base.Function<Long,DecoratedKey>	keyFetcher
protected final OnDiskIndex.PointerLevel[]	levels
protected final ByteBuffer	maxKey
protected final ByteBuffer	maxTerm
protected final ByteBuffer	minKey
protected final ByteBuffer	minTerm
protected final OnDiskIndexBuilder.Mode	mode
protected final OnDiskIndexBuilder.TermSize	termSize

Constructor Summary

Constructors

Constructor	Description
OnDiskIndex(File index, AbstractType<?> cmp, com.google.common.base.Function<Long,DecoratedKey> keyReader)

Method Summary

Modifier and Type	Method	Description
void	close()
AbstractType<?>	getComparator()
String	getIndexPath()
boolean	hasMarkedPartials()
Iterator<OnDiskIndex.DataTerm>	iterator()
Iterator<OnDiskIndex.DataTerm>	iteratorAt(ByteBuffer query, OnDiskIndex.IteratorOrder order, boolean inclusive)
OnDiskIndex.DataTerm	max()
ByteBuffer	maxKey()
ByteBuffer	maxTerm()
OnDiskIndex.DataTerm	min()
ByteBuffer	minKey()
ByteBuffer	minTerm()
OnDiskIndexBuilder.Mode	mode()
RangeIterator<Long,Token>	search(Expression exp)	Search for rows which match all of the terms inside the given expression in the index file.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Details

descriptor

public final Descriptor descriptor

mode

protected final OnDiskIndexBuilder.Mode mode

termSize

protected final OnDiskIndexBuilder.TermSize termSize

comparator

protected final AbstractType<?> comparator

indexFile

protected final MappedBuffer indexFile

indexSize

protected final long indexSize

hasMarkedPartials

protected final boolean hasMarkedPartials

keyFetcher

protected final com.google.common.base.Function<Long,DecoratedKey> keyFetcher

indexPath

protected final String indexPath

levels

protected final OnDiskIndex.PointerLevel[] levels

dataLevel

protected final OnDiskIndex.DataLevel dataLevel

minTerm

protected final ByteBuffer minTerm

maxTerm

protected final ByteBuffer maxTerm

minKey

protected final ByteBuffer minKey

maxKey

protected final ByteBuffer maxKey

Constructor Details

OnDiskIndex

public OnDiskIndex(File index,
 AbstractType<?> cmp,
 com.google.common.base.Function<Long,DecoratedKey> keyReader)

Method Details

hasMarkedPartials

public boolean hasMarkedPartials()

mode

public OnDiskIndexBuilder.Mode mode()

minTerm

public ByteBuffer minTerm()

maxTerm

public ByteBuffer maxTerm()

minKey

public ByteBuffer minKey()

maxKey

public ByteBuffer maxKey()

min

public OnDiskIndex.DataTerm min()

max

public OnDiskIndex.DataTerm max()

search

public RangeIterator<Long,Token> search(Expression exp)

Search for rows which match all of the terms inside the given expression in the index file.

Parameters:

exp - The expression to use for the query.

Returns:

Iterator which contains rows for all of the terms from the given range.

iteratorAt

public Iterator<OnDiskIndex.DataTerm> iteratorAt(ByteBuffer query,
 OnDiskIndex.IteratorOrder order,
 boolean inclusive)

iterator

public Iterator<OnDiskIndex.DataTerm> iterator()

Specified by:

iterator in interface Iterable<OnDiskIndex.DataTerm>

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

getComparator

public AbstractType<?> getComparator()

getIndexPath

public String getIndexPath()