Package org.apache.druid.query.aggregation

Class AbstractSerializablePairLongObjectBufferStore<T extends SerializablePair<Long,?>>

java.lang.Object

org.apache.druid.query.aggregation.AbstractSerializablePairLongObjectBufferStore<T>

Direct Known Subclasses:

SerializablePairLongDoubleBufferStore, SerializablePairLongFloatBufferStore, SerializablePairLongLongBufferStore, SerializablePairLongStringBufferStore

public abstract class AbstractSerializablePairLongObjectBufferStore<T extends SerializablePair<Long,?>>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AbstractSerializablePairLongObjectBufferStore.TransferredBuffer	contains serialized data that is compressed and delta-encoded (Long) It's ready to be transferred to a WritableByteChannel

Method Summary

Modifier and Type	Method	Description
abstract AbstractSerializablePairLongObjectColumnHeader<T>	createColumnHeader()
abstract AbstractSerializablePairLongObjectDeltaEncodedStagedSerde<T>	createDeltaEncodedSerde(AbstractSerializablePairLongObjectColumnHeader<T> columnHeader)
IOIterator<T>	iterator()
void	store(T pairLongObject)
AbstractSerializablePairLongObjectBufferStore.TransferredBuffer	transferToRowWriter(ByteBufferProvider byteBufferProvider, SegmentWriteOutMedium segmentWriteOutMedium)	each call transfers the temporary buffer into an encoded, block-compessed buffer of the segment.

Methods inherited from class java.lang.Object

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

Method Details

store

public void store(@Nullable
 T pairLongObject)
           throws IOException

Throws:

IOException

transferToRowWriter

public AbstractSerializablePairLongObjectBufferStore.TransferredBuffer transferToRowWriter(ByteBufferProvider byteBufferProvider,
 SegmentWriteOutMedium segmentWriteOutMedium)
                                                                                    throws IOException

each call transfers the temporary buffer into an encoded, block-compessed buffer of the segment. It is ready to be transferred to a WritableByteChannel

Parameters:

byteBufferProvider - - provides a ByteBuffer used for block compressed encoding

segmentWriteOutMedium - - used to create temporary storage

Returns:

encoded buffer ready to be stored

Throws:

IOException

createColumnHeader

@Nonnull
public abstract AbstractSerializablePairLongObjectColumnHeader<T> createColumnHeader()

createDeltaEncodedSerde

public abstract AbstractSerializablePairLongObjectDeltaEncodedStagedSerde<T> createDeltaEncodedSerde(AbstractSerializablePairLongObjectColumnHeader<T> columnHeader)

iterator

public IOIterator<T> iterator()
                       throws IOException

Throws:

IOException