io.druid.query.groupby.epinephelinae

Interface Grouper.KeySerde<T>

Enclosing interface:

Grouper<KeyType>

public static interface Grouper.KeySerde<T>

Possibly-stateful object responsible for serde and comparison of keys. Does not need to be thread-safe.

Method Summary

Modifier and Type	Method and Description
Grouper.KeyComparator	bufferComparator() Return an object that knows how to compare two serialized keys.
T	fromByteBuffer(ByteBuffer buffer, int position) Deserialize a key from a buffer.
Class<T>	keyClazz() Class of the keys.
int	keySize() Size of the keys returned by toByteBuffer(Object) (which must be a fixed size)
void	reset() Reset the keySerde to its initial state.
ByteBuffer	toByteBuffer(T key) Serialize a key.

Method Detail

keySize

int keySize()

Size of the keys returned by toByteBuffer(Object) (which must be a fixed size)

keyClazz

Class<T> keyClazz()

Class of the keys.

toByteBuffer

ByteBuffer toByteBuffer(T key)

Serialize a key. This will be called by the #aggregate(Comparable) method. The buffer will not be retained after the aggregate method returns, so reusing buffers is OK.

This method may return null, which indicates that some internal resource limit has been reached and no more keys can be generated. In this situation you can call reset() and try again, although beware the caveats on that method.

Parameters:

key - key object

Returns:

serialized key, or null if we are unable to serialize more keys due to resource limits

fromByteBuffer

T fromByteBuffer(ByteBuffer buffer,
                 int position)

Deserialize a key from a buffer. Will be called by the Grouper.iterator(boolean) method.

Parameters:

buffer - buffer containing the key

position - key start position in the buffer

Returns:

key object

bufferComparator

Grouper.KeyComparator bufferComparator()

Return an object that knows how to compare two serialized keys. Will be called by the Grouper.iterator(boolean) method if sorting is enabled.

Returns:

comparator for keys

reset

void reset()

Reset the keySerde to its initial state. After this method is called, fromByteBuffer(ByteBuffer, int) and bufferComparator() may no longer work properly on previously-serialized keys.