io.druid.segment.data

Class CompressedObjectStrategy<T extends Buffer>

java.lang.Object

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

All Implemented Interfaces:

ObjectStrategy<ResourceHolder<T>>, Comparator<ResourceHolder<T>>

Direct Known Subclasses:

FixedSizeCompressedObjectStrategy, VSizeCompressedObjectStrategy

public class CompressedObjectStrategy<T extends Buffer>
extends Object
implements ObjectStrategy<ResourceHolder<T>>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	CompressedObjectStrategy.BufferConverter<T>
static class	CompressedObjectStrategy.CompressionStrategy Compression strategy is used to compress block of bytes without knowledge of what data the bytes represents.
static interface	CompressedObjectStrategy.Compressor
static interface	CompressedObjectStrategy.Decompressor
static class	CompressedObjectStrategy.LZ4Compressor
static class	CompressedObjectStrategy.LZ4Decompressor
static class	CompressedObjectStrategy.LZFCompressor
static class	CompressedObjectStrategy.LZFDecompressor
static class	CompressedObjectStrategy.UncompressedCompressor
static class	CompressedObjectStrategy.UncompressedDecompressor

Field Summary

Fields

Modifier and Type	Field and Description
protected CompressedObjectStrategy.BufferConverter<T>	converter
protected CompressedObjectStrategy.Decompressor	decompressor
static CompressedObjectStrategy.CompressionStrategy	DEFAULT_COMPRESSION_STRATEGY
protected ByteOrder	order

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	CompressedObjectStrategy(ByteOrder order, CompressedObjectStrategy.BufferConverter<T> converter, CompressedObjectStrategy.CompressionStrategy compression)

Method Summary

Modifier and Type	Method and Description
protected ByteBuffer	bufferFor(T val)
int	compare(ResourceHolder<T> o1, ResourceHolder<T> o2)
protected void	decompress(ByteBuffer buffer, int numBytes, ByteBuffer buf)
ResourceHolder<T>	fromByteBuffer(ByteBuffer buffer, int numBytes) Convert values from their underlying byte representation.
Class<? extends ResourceHolder<T>>	getClazz()
byte[]	toBytes(ResourceHolder<T> holder)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Comparator

comparing, comparing, comparingDouble, comparingInt, comparingLong, equals, naturalOrder, nullsFirst, nullsLast, reversed, reverseOrder, thenComparing, thenComparing, thenComparing, thenComparingDouble, thenComparingInt, thenComparingLong

Field Detail

DEFAULT_COMPRESSION_STRATEGY

public static final CompressedObjectStrategy.CompressionStrategy DEFAULT_COMPRESSION_STRATEGY

order

protected final ByteOrder order

converter

protected final CompressedObjectStrategy.BufferConverter<T extends Buffer> converter

decompressor

protected final CompressedObjectStrategy.Decompressor decompressor

Constructor Detail

CompressedObjectStrategy

protected CompressedObjectStrategy(ByteOrder order,
                                   CompressedObjectStrategy.BufferConverter<T> converter,
                                   CompressedObjectStrategy.CompressionStrategy compression)

Method Detail

getClazz

public Class<? extends ResourceHolder<T>> getClazz()

Specified by:

getClazz in interface ObjectStrategy<ResourceHolder<T extends Buffer>>

fromByteBuffer

public ResourceHolder<T> fromByteBuffer(ByteBuffer buffer,
                                        int numBytes)

Description copied from interface: ObjectStrategy

Convert values from their underlying byte representation. Implementations of this method must not change the given buffer mark, or limit, but may modify its position. Use buffer.asReadOnlyBuffer() or buffer.duplicate() if mark or limit need to be set.

Specified by:

fromByteBuffer in interface ObjectStrategy<ResourceHolder<T extends Buffer>>

Parameters:

buffer - buffer to read value from

numBytes - number of bytes used to store the value, starting at buffer.position()

Returns:

an object created from the given byte buffer representation

decompress

protected void decompress(ByteBuffer buffer,
                          int numBytes,
                          ByteBuffer buf)

toBytes

public byte[] toBytes(ResourceHolder<T> holder)

Specified by:

toBytes in interface ObjectStrategy<ResourceHolder<T extends Buffer>>

bufferFor

protected ByteBuffer bufferFor(T val)

compare

public int compare(ResourceHolder<T> o1,
                   ResourceHolder<T> o2)

Specified by:

compare in interface Comparator<ResourceHolder<T extends Buffer>>