io.druid.segment.data

Class GenericIndexed<T>

java.lang.Object

io.druid.segment.data.GenericIndexed<T>

All Implemented Interfaces:

Indexed<T>, Closeable, AutoCloseable, Iterable<T>

public class GenericIndexed<T>
extends Object
implements Indexed<T>, Closeable

A generic, flat storage mechanism. Use static methods fromArray() or fromIterable() to construct. If input is sorted, supports binary search index lookups. If input is not sorted, only supports array-like index lookups. V1 Storage Format: byte 1: version (0x1) byte 2 == 0x1 => allowReverseLookup bytes 3-6 => numBytesUsed bytes 7-10 => numElements bytes 10-((numElements * 4) + 10): integers representing *end* offsets of byte serialized values bytes ((numElements * 4) + 10)-(numBytesUsed + 2): 4-byte integer representing length of value, followed by bytes for value

Field Summary

Fields

Modifier and Type	Field and Description
static int	INITIAL_CACHE_CAPACITY
static ObjectStrategy<String>	stringStrategy

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
static <T> GenericIndexed<T>	fromArray(T[] objects, ObjectStrategy<T> strategy)
static <T> GenericIndexed<T>	fromIterable(Iterable<T> objectsIterable, ObjectStrategy<T> strategy)
T	get(int index)
Class<? extends T>	getClazz()
long	getSerializedSize()
int	indexOf(T value)
Iterator<T>	iterator()
static <T> GenericIndexed<T>	read(ByteBuffer buffer, ObjectStrategy<T> strategy)
int	size()
GenericIndexed<T>	withCache(int maxBytes) The returned GenericIndexed must be closed to release the underlying memory
void	writeToChannel(WritableByteChannel channel)

Methods inherited from class java.lang.Object

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

Field Detail

INITIAL_CACHE_CAPACITY

public static final int INITIAL_CACHE_CAPACITY

See Also:

Constant Field Values

stringStrategy

public static ObjectStrategy<String> stringStrategy

Method Detail

fromArray

public static <T> GenericIndexed<T> fromArray(T[] objects,
                              ObjectStrategy<T> strategy)

fromIterable

public static <T> GenericIndexed<T> fromIterable(Iterable<T> objectsIterable,
                                 ObjectStrategy<T> strategy)

getClazz

public Class<? extends T> getClazz()

Specified by:

getClazz in interface Indexed<T>

size

public int size()

Specified by:

size in interface Indexed<T>

get

public T get(int index)

Specified by:

get in interface Indexed<T>

indexOf

public int indexOf(T value)

Specified by:

indexOf in interface Indexed<T>

getSerializedSize

public long getSerializedSize()

writeToChannel

public void writeToChannel(WritableByteChannel channel)
                    throws IOException

Throws:

IOException

withCache

public GenericIndexed<T> withCache(int maxBytes)

The returned GenericIndexed must be closed to release the underlying memory

Parameters:

maxBytes - maximum size in bytes of the lookup cache

Returns:

a copy of this GenericIndexed with a lookup cache.

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

read

public static <T> GenericIndexed<T> read(ByteBuffer buffer,
                         ObjectStrategy<T> strategy)

iterator

public Iterator<T> iterator()

Specified by:

iterator in interface Iterable<T>