io.druid.segment.data

Class GenericIndexed<T>

java.lang.Object

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

All Implemented Interfaces:

Indexed<T>, Iterable<T>

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

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 ObjectStrategy<String>	STRING_STRATEGY

Method Summary

Methods

Modifier and Type	Method and Description
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)
io.druid.segment.data.GenericIndexed.BufferIndexed	singleThreaded() Create a non-thread-safe Indexed, which may perform better than the underlying Indexed.
int	size()
void	writeToChannel(WritableByteChannel channel)

Methods inherited from class java.lang.Object

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

Field Detail

STRING_STRATEGY

public static final ObjectStrategy<String> STRING_STRATEGY

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>

iterator

public Iterator<T> iterator()

Specified by:

iterator in interface Iterable<T>

getSerializedSize

public long getSerializedSize()

writeToChannel

public void writeToChannel(WritableByteChannel channel)
                    throws IOException

Throws:

IOException

singleThreaded

public io.druid.segment.data.GenericIndexed.BufferIndexed singleThreaded()

Create a non-thread-safe Indexed, which may perform better than the underlying Indexed.

Returns:

a non-thread-safe Indexed

read

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