Class OnDiskIndexBuilder
java.lang.Object
org.apache.cassandra.index.sasi.disk.OnDiskIndexBuilder
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic enumstatic enum -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final intstatic final intstatic final intstatic final int -
Constructor Summary
ConstructorsConstructorDescriptionOnDiskIndexBuilder(AbstractType<?> keyComparator, AbstractType<?> comparator, OnDiskIndexBuilder.Mode mode) OnDiskIndexBuilder(AbstractType<?> keyComparator, AbstractType<?> comparator, OnDiskIndexBuilder.Mode mode, boolean marksPartials) -
Method Summary
Modifier and TypeMethodDescriptionadd(ByteBuffer term, DecoratedKey key, long keyPosition) protected static voidlongprotected booleanfinish(Descriptor descriptor, File file) protected voidfinish(Descriptor descriptor, Pair<ByteBuffer, ByteBuffer> range, File file, TermIterator terms) booleanFinishes up index building process by creating/populating index file.voidfinish(Pair<ByteBuffer, ByteBuffer> range, File file, TermIterator terms) booleanisEmpty()
-
Field Details
-
BLOCK_SIZE
public static final int BLOCK_SIZE- See Also:
-
MAX_TERM_SIZE
public static final int MAX_TERM_SIZE- See Also:
-
SUPER_BLOCK_SIZE
public static final int SUPER_BLOCK_SIZE- See Also:
-
IS_PARTIAL_BIT
public static final int IS_PARTIAL_BIT- See Also:
-
-
Constructor Details
-
OnDiskIndexBuilder
public OnDiskIndexBuilder(AbstractType<?> keyComparator, AbstractType<?> comparator, OnDiskIndexBuilder.Mode mode) -
OnDiskIndexBuilder
public OnDiskIndexBuilder(AbstractType<?> keyComparator, AbstractType<?> comparator, OnDiskIndexBuilder.Mode mode, boolean marksPartials)
-
-
Method Details
-
add
-
estimatedMemoryUse
public long estimatedMemoryUse() -
isEmpty
public boolean isEmpty() -
finish
-
finish
Finishes up index building process by creating/populating index file.- Parameters:
indexFile- The file to write index contents to.- Returns:
- true if index was written successfully, false otherwise (e.g. if index was empty).
- Throws:
FSWriteError- on I/O error.
-
finish
- Throws:
FSWriteError
-
finish
protected void finish(Descriptor descriptor, Pair<ByteBuffer, ByteBuffer> range, File file, TermIterator terms) -
alignToBlock
- Throws:
IOException
-