io.druid.segment

Class CompressedVSizeIndexedSupplier

java.lang.Object

io.druid.segment.CompressedVSizeIndexedSupplier

All Implemented Interfaces:

com.google.common.base.Supplier<IndexedMultivalue<IndexedInts>>, WritableSupplier<IndexedMultivalue<IndexedInts>>

public class CompressedVSizeIndexedSupplier
extends Object
implements WritableSupplier<IndexedMultivalue<IndexedInts>>

Format - byte 1 - version offsets - indexed integers of length num of rows + 1 representing offsets of starting index of first element of each row in values index and last element equal to length of values column, the last element in the offsets represents the total length of values column. values - indexed integer representing values in each row

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CompressedVSizeIndexedSupplier.CompressedVSizeIndexed

Method Summary

Methods

Modifier and Type	Method and Description
static CompressedVSizeIndexedSupplier	fromByteBuffer(ByteBuffer buffer, ByteOrder order)
static CompressedVSizeIndexedSupplier	fromIterable(Iterable<IndexedInts> objectsIterable, int maxValue, ByteOrder byteOrder, CompressedObjectStrategy.CompressionStrategy compression)
IndexedMultivalue<IndexedInts>	get()
long	getSerializedSize()
void	writeToChannel(WritableByteChannel channel)

Methods inherited from class java.lang.Object

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

Method Detail

getSerializedSize

public long getSerializedSize()

Specified by:

getSerializedSize in interface WritableSupplier<IndexedMultivalue<IndexedInts>>

writeToChannel

public void writeToChannel(WritableByteChannel channel)
                    throws IOException

Specified by:

writeToChannel in interface WritableSupplier<IndexedMultivalue<IndexedInts>>

Throws:

IOException

fromByteBuffer

public static CompressedVSizeIndexedSupplier fromByteBuffer(ByteBuffer buffer,
                                            ByteOrder order)

fromIterable

public static CompressedVSizeIndexedSupplier fromIterable(Iterable<IndexedInts> objectsIterable,
                                          int maxValue,
                                          ByteOrder byteOrder,
                                          CompressedObjectStrategy.CompressionStrategy compression)

get

public IndexedMultivalue<IndexedInts> get()

Specified by:

get in interface com.google.common.base.Supplier<IndexedMultivalue<IndexedInts>>